from concurrent.futures import ThreadPoolExecutor,ProcessPoolExecutor
import time
import os
​
pool &＃61; ThreadPoolExecutor(5) # 括号内可以传参数指定线程内的线程个数,也可以不传,不传默认是当前所在计算机的cpu个数乘5
pool &＃61; ProcessPoolExecutor(5)
​
def task(n):print(n)time.sleep(2)return n**2
​
t_list &＃61; []
for i in range(20):res &＃61; pool.submit(task,1) # 朝线程池中提交任务,异步提交print(res.result()) # 原地等待任务的返回结果,将并发变为串行
t_list.append()
​
pool.shutdown() # 关闭池子,等待池子中所有的任务执行完毕后,才会往下运行代码
for p in t_list:print(&＃39;>>>:&＃39;,p.result())

from concurrent.futures import ThreadPoolExecutor,ProcessPoolExecutor
import time
​
pool &＃61; ProcessPoolExecutor() # 不传值时默认是当前计算机cpu的个数
​
def task(n):print(n,os.getpid()) # 查看当前进程号time.sleep(2)return n**2
​
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:t_list &＃61; []for i in range(20):res &＃61; pool.submit(task,1) # 朝线程池中提交任务,异步提交print(res.result()) # 原地等待任务的返回结果,将并发变为串行
t_list.append()
​pool.shutdown() # 关闭池子,等待池子中所有的任务执行完毕后,才会往下运行代码for p in t_list:print(&＃39;>>>:&＃39;,p.result())

from concurrent.futures import ThreadPoolExecutor,ProcessPoolExecutor
import time
​
pool &＃61; ProcessPoolExecutor(5)
​
def task(n):print(n,os.getpid()) # 查看当前进程号time.sleep(2)return n**2
​
def callback(n):print(&＃39;拿到了异步提交任务的返回结果:&＃39;,n)
​
if __name__ &＃61;&＃61; &＃39;__main__&＃39;:t_list &＃61; []for i in range(20):res &＃61; pool.submit(task,1).add_done_callback(call_back) # 提交任务时,绑定一个回调函数,一旦任务有结果,立刻执行对应的回调函数t_list.append(res)

# 基于yield并发执行 切换&＃43;保存状态 效率反而降低了
import time
​
def func1():while True:10000000&＃43;1yielddef func2():g &＃61; func1()for i in range(10000000):time.sleep(100) # 模拟IO,yield并不会捕捉到自动切换i&＃43;1next(g)start &＃61; time.time()
func2()
stop &＃61; time.time()
print(stop-start)

from gevent import monkey;monkey.patch_all() # 由于该模块经常被使用,所以建议写成一行
from gevent import spawn
import time
​
def heng():print(&＃39;哼&＃39;)time.slepp(2)print(&＃39;哼&＃39;)def ha():print(&＃39;哈&＃39;)time.sleep(3)print(&＃39;哈&＃39;)start &＃61; time.time()
g1 &＃61; spawn(heng)
g2 &＃61; spawn(ha) # spawn会监测所有的任务
g1.join()
g2.join()
print(time.time() - start)
&＃39;&＃39;&＃39;
哼
哈
3.002878...秒
&＃39;&＃39;&＃39;

import socket
from Thread import Thread,current_thread
​
def client():client &＃61; socket.socket()client.connect((&＃39;127.0.0.1&＃39;,8080))n &＃61; 0while True:data &＃61; &＃39;%s %s&＃39;%(current_thread().name,n)client.send(data.encode(&＃39;utf--8&＃39;))res &＃61; client.recv(1024)print(res.decode(&＃39;utf-8&＃39;))n &＃43;&＃61; 1for i in range(400):t &＃61; Thread(target&＃61;client)t.start()

import socket
from gevent import monkey;monkey.patch_all()行
from gevent import spawn
​
server &＃61; socket.socket()
server.bind((&＃39;127.0.0.1&＃39;,8080))
server.listen(5)
​
def talk(conn):while True:try:data &＃61; conn.recv(1024)if len(data) &＃61;&＃61; 0:breakprint(data.decode(&＃39;utf-8&＃39;))conn.send(data.upper())except ConnectResetError as e:print(e)breakconn.close()
​
def server_run():while True:conn,addr &＃61; server.accept()spawn(talk,conn)if __name__ &＃61;&＃61; &＃39;__main__&＃39;:g1 &＃61; spawn(server_run)g1.join()