import threading
from multiprocessing import Process,Queue
import time
def thre(qq):qq.put([1,'xixi',2])if __name__ =='__main__':q = Queue()p = Process(target=thre,args=(q,))#进程中，因为进程内存是独立的，所以不能相互调用，必须传入参数，这个q其实是复制了一份Queue的实例，如果和线程一样不传参数，就会报错** not find。。。因为内存不共享。
#p =threading.Thread(target=thre) #线程中，不传参数是可以调用函数thre，因为他们是在同一个内存地址下操作【上面改为def thre():】，当然传参数也没问题。
    p.start()print(q.get())#进程之间想要有联系，主动无法联系，这是硬伤，就如qq和word一样，但是如果非要他们有联系，就是从word复制文字到qq里（或者qq复制图片文字到word里面这样），这样貌似两者有联系，实际上只是克隆了那段文字的关系，但是看起来好像就有联系了，那么python中process之间的通信就是可以考虑通过    Queue来实现，Queue内部操作其实就是通过pickle的功能来实现传参数等各种联系的
还有一个是pipe：通过管道来传递，也是建立一个pipe的实例化对象。

from multiprocessing import Process,Pipedef f(conn):conn.send('balabala')print(conn.recv())if __name__=='__main__':parent_conn,child_conn=Pipe()#实例化后是返回两个值，一个是父接头一个是子接头，因为是管道。p = Process(target=f,args=(child_conn,))p.start()print(parent_conn.recv())parent_conn.send('babababa')

from multiprocessing import Process,Manager
import time,osdef thre(dd,ll):dd[os.getpid()] = os.getppid()ll.append(os.getpid())print(ll)print(dd)if __name__ =='__main__':manager = Manager()d = manager.dict()l = manager.list(range(3))t_list = []for i in range(10):p = Process(target=thre,args=(d,l))p.start()t_list.append(p)for res in t_list:res.join()#等待的意思

from multiprocessing import Pool
import time,osdef thre(dd):time.sleep(1)print('the process:',os.getpid())return dd+100
def g(c):print('haha',c,os.getpid())#start_time = time.time()
# l=[]
if __name__ =='__main__':p_ = Pool(3)#允许同时运行的进程数为3。print(os.getpid())for i in range(10):p_.apply_async(func=thre,args=(i,),callback=g)#【callback是回调函数，传的参数是thre的返回值】
    p_.close()p_.join()#这里如果不加join，在并行中会直接close，程序会直接关闭，加了join，主进程就会等待子进程结束以后最后才关闭，这个只在并行中有用，串行中没有什么作用。一定要先close再join

import geventdef fun1():print('runing 1 ...')gevent.sleep(2)#模仿ioprint('running 2 ...')def fun2():print('running 3 ...')gevent.sleep(3)print('running 4')def fun3():print('running 5 ...')gevent.sleep(0)print('end?')gevent.joinall([gevent.spawn(fun1),gevent.spawn(fun2),gevent.spawn(fun3)])

import gevent,time
import urllib.request as ul
from gevent import monkey
monkey.patch_all()#这个标识代表把所有程序都当做io直接切换操作，不加这句话，因为gevent不会辨认出urllib的有io操作，相当于串行操作。
def f(url):print('GET %s'%url)res = ul.urlopen(url).read()print('recv bytes %s from %s'%(len(res),url))time_start = time.time()
l=['https://www.python.org/','http://km.58.com/','http://kan.sogou.com/dongman/','http://news.sohu.com/']
for i in l:f(i)
print('同步时间：',time.time()-time_start)
async_time = time.time()
gevent.joinall([gevent.spawn(f,'https://www.python.org/'),gevent.spawn(f,'http://km.58.com/'),gevent.spawn(f,'http://kan.sogou.com/dongman/'),gevent.spawn(f,'http://news.sohu.com/')])
print('异步时间：',time.time()-async_time)

import selectors,socket
sel = selectors.DefaultSelector()def accept(sock,mask):conn,addr = sock.accept()conn.setblocking(False)sel.register(conn,selectors.EVENT_READ,read)def read(conn,mask):data = conn.recv(1024).decode()if data:conn.send(('haha+%s'%data).encode())else:print('发什么?',conn)sel.unregister(conn)conn.close()sock = socket.socket()
sock.bind(('localhost',5000))
sock.listen(1000)
sel.register(sock,selectors.EVENT_READ,accept)
while True:events= sel.select()for key,mask in events:callback = key.datacallback(key.fileobj,mask)