python3中多進(jìn)程如何共享全局變量？

上代碼

from multiprocessing import Pool, Queue
import os, time, random

def long_time_task(name, queue):
    print('Run task %s (%s)...' % (name, os.getpid()))
    start = time.time()
    time.sleep(random.random() * 3)
    end = time.time()
    print('Task %s runs %0.2f seconds.' % (name, (end - start)))
    print(queue.get())

if __name__=='__main__':
    print('Parent process %s.' % os.getpid())
    p = Pool(2)
    q = Queue(10)
    for j in range(10):
        q.put(j)
    for i in range(5):
        p.apply_async(long_time_task, args=(i, q))
    print('Waiting for all subprocesses done...')
    p.close()
    p.join()
    print('All subprocesses done.')

以上代碼是不行的，不會(huì)執(zhí)行想要的效果。
如果我想在多個(gè)進(jìn)程中共用一個(gè)全局隊(duì)列，應(yīng)該如何操作？Google過(guò)了，還是不太清除其中的知識(shí)點(diǎn)。麻煩前輩們解惑。

回答

編輯回答

若相惜

多進(jìn)程共用全局隊(duì)列，那么無(wú)外乎兩種情況，一種全局隊(duì)列存在內(nèi)存中，比如用redis，一種全局隊(duì)列存在硬盤(pán)上，比如數(shù)據(jù)庫(kù)mysql。
多進(jìn)程通信的話還可以考慮pipe和socket, multiprocessing.Manager.Queue就是pipe通信。

from multiprocessing import Pool, Manager
import os, time, random

def long_time_task(name, queue):
    print('Run task %s (%s)...' % (name, os.getpid()))
    start = time.time()
    time.sleep(random.random() * 3)
    end = time.time()
    print('Task %s runs %0.2f seconds.' % (name, (end - start)))
    print(queue.get())

if __name__=='__main__':
    print('Parent process %s.' % os.getpid())
    p = Pool(2)
    q = Manager().Queue(10)
    for j in range(10):
        q.put(j)
    for i in range(5):
        p.apply_async(long_time_task, args=(i, q))
    print('Waiting for all subprocesses done...')
    p.close()
    p.join()
    print('All subprocesses done.')

2017年10月29日 23:13