进程数据共享

标签：reading   process   tar   font   def   共享   直接   join   roc   

进程数据共享：

1、线程数据，可以直接访问

import threading
import queue
#多线程访问时,q为共享；
def thr_f():
    q.put(["1,2,3"])
if __name__=="__main__":
    q = queue.Queue()
    t = threading.Thread(target=thr_f)
    t.start()
    print (q.get())
2、进程之间的访问方式1（Queue)：

#当多进程访问时，道路相同；
#只是需要将q做为参数，传递给子进程；

from multiprocessing import Queue,Process

def mul_f(qq):
    qq.put([1,2,3])

if __name__ =="__main__":
    q = Queue()
    p = Process(target=mul_f,args = (q,))
    p.start()
    print (q.get())
3、进程之间数据访问方式2（管道）：
   #类似电话线的2端，一端发送一端接收.

from multiprocessing import Process,Pipe

def Pip_f(conn):
    conn.send("世界你好！")
    print (conn.recv())
    conn.close()

if __name__=="__main__":
    par_conn,chi_conn = Pipe()
    p = Process(target=Pip_f,args=(chi_conn,))
    par_conn.send("kaka!")
    p.start()
    print (par_conn.recv())
    p.join()

进程数据共享

标签：reading   process   tar   font   def   共享   直接   join   roc   

原文地址：http://www.cnblogs.com/wulafuer/p/7953626.html