from concurrent.futures import ProcessPoolExecutor,ThreadPoolExecutor
import  time,random,osdef task():print('%s is running'%os.getpid())i=random.randint(1,3)time.sleep(i)return iif __name__ == '__main__':p=ProcessPoolExecutor(4)l=[]for i in range(10):res = p.submit(task).result()#等待任务执行完毕,返回结果print(res)print('主')

from concurrent.futures import ProcessPoolExecutor,ThreadPoolExecutor
import  time,random,osdef task():print('%s is running'%os.getpid())i=random.randint(1,3)time.sleep(i)return iif __name__ == '__main__':p=ProcessPoolExecutor(4)l=[]for i in range(10):future=p.submit(task)#只替提交任务
        l.append(future)p.shutdown(wait=True)#关闭进程池入口,并在原地等待所有进程任务执行完毕for i in l:print(i.result())print('主')

from concurrent.futures import ProcessPoolExecutor
import time,os
import requestsdef get(url):print('%s GET %s' %(os.getpid(),url))time.sleep(3)response=requests.get(url)if response.status_code == 200:res=response.textelse:res='下载失败'return resdef parse(future):time.sleep(1)res=future.result()print('%s 解析结果为%s' %(os.getpid(),len(res)))if __name__ == '__main__':urls=['https://www.baidu.com','https://www.sina.com.cn','https://www.tmall.com','https://www.jd.com','https://www.python.org','https://www.openstack.org','https://www.baidu.com','https://www.baidu.com','https://www.baidu.com',]p=ProcessPoolExecutor(9)start=time.time()for url in urls:future=p.submit(get,url)future.add_done_callback(parse)#parse会在任务运行完毕后自动触发,然后接收一个参数future对象,回调函数的执行是在主进程里,而线程中的回调函数是由空闲的线程来执行
p.shutdown(wait=True)print('主',time.time()-start)print('主',os.getpid())

from concurrent.futures import ThreadPoolExecutor
import socket
from threading import current_thread
IP='127.0.0.1'
PORT=8085
ADDRESS=(IP,PORT)
BUFFSIZE=1024
t = ThreadPoolExecutor(4)def communicate(conn,addr):while True:try:data=conn.recv(BUFFSIZE)if not data:print('%s客户端断开....'%addr)breakprint('>>>>%s  端口:%s 线程:%s'%(data.decode('utf-8'),addr[1],current_thread().name))conn.send(data.upper())except ConnectionResetError:breakconn.close()if __name__ == '__main__':server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)server.bind(ADDRESS)server.listen(2)print(current_thread().name)while True:conn,addr=server.accept()t.submit(communicate, conn,addr)

import socket
IP='127.0.0.1'
PORT=8085
ADDRESS=(IP,PORT)
BUFFSIZE=1024client=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
client.connect(ADDRESS)while True:msg=input('>>>>').strip()if len(msg)==0:continueif msg=='q':breakclient.send(msg.encode('utf-8'))data = client.recv(BUFFSIZE)print(data.decode('utf-8'))client.close()

#串行执行
import timedef func1():for i in range(10000000):i+1def func2():for i in range(10000000):i+1start = time.time()
func1()
func2()
stop = time.time()
print(stop - start)#基于yield并发执行
import time
def func1():while True:yielddef func2():g=func1()for i in range(10000000):i+1next(g)start=time.time()
func2()
stop=time.time()
print(stop-start)#2.7103893756866455

from gevent import monkey;monkey.patch_all()
from gevent import spawn
import socket
from threading import current_thread
IP='127.0.0.1'
PORT=8086
ADDRESS=(IP,PORT)
BUFFSIZE=1024def communicate(conn,addr):while True:try:data=conn.recv(BUFFSIZE)if not data:print('%s客户端断开....'%addr)breakconn.send(data.upper())except ConnectionResetError:breakdef server():server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)server.bind(ADDRESS)server.listen(2)print(current_thread().name)while True:conn,addr=server.accept()spawn(communicate,conn,addr)if __name__ == '__main__':s1=spawn(server)s1.join()

import socket
from threading import Thread,current_threadIP = '127.0.0.1'
PORT = 8086
ADDRESS = (IP, PORT)
BUFFSIZE = 1024
def client():client=socket.socket(socket.AF_INET,socket.SOCK_STREAM)client.connect(ADDRESS)n=0while True:msg='%s say hello %s' %(current_thread().name,n)n+=1client.send(msg.encode('utf-8'))data=client.recv(BUFFSIZE)print(data.decode('utf-8'))if __name__ == '__main__':for i in range(500):t=Thread(target=client)t.start()