【Python 学习】多进程

多进程

linux平台例子：
Unix/Linux操作系统提供了一个

fork()

系统调用，它非常特殊。普通的函数调用，调用一次，返回一次，但是

fork()

调用一次，返回两次，因为操作系统自动把当前进程（称为父进程）复制了一份（称为子进程），然后，分别在父进程和子进程内返回。子进程永远返回

0

，而父进程返回子进程的ID。这样做的理由是，一个父进程可以fork出很多子进程，所以，父进程要记下每个子进程的ID，而子进程只需要调用

getppid()

就可以拿到父进程的ID。

import os,random

print 'Process (%s) start...' % os.getpid()

p1 = os.fork()
if pid==0:
#第一次执行返回0的情况
print 'I am child process (%s) and my parent is %s.' % (os.getpid(), os.getppid())
else:
#第一次执行返回子进程ID的情况
print 'I (%s) just created a child process (%s).' % (os.getpid(), pid)

windows例子

from multiprocessing import Process
import os

# 子进程要执行的代码
def run_proc(name):
print 'Run child process %s (%s)...' % (name, os.getpid())

#创建一个Process实例，用start()方法启动
#join()方法可以等待子进程结束后再继续往下运行，通常用于进程间的同步

if __name__=='__main__':
print 'Parent process %s.' % os.getpid()
p = Process(target=run_proc, args=('test',))
print 'Process will start.'
p.start()
p.join()
print 'Process end.'

#执行结果如下：

Parent process 928.
Process will start.
Run child process test (929)...
Process end.

多进程使用队列进行 进程间通信

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

# 写数据进程执行的代码:
def write(q):
for value in ['A', 'B', 'C']:
print 'Put %s to queue...' % value
q.put(value)
time.sleep(random.random())

# 读数据进程执行的代码:
def read(q):
while True:
value = q.get(True)
print 'Get %s from queue.' % value

if __name__=='__main__':
# 父进程创建Queue，并传给各个子进程：
q = Queue()
pw = Process(target=write, args=(q,))
pr = Process(target=read, args=(q,))
# 启动子进程pw，写入:
pw.start()
# 启动子进程pr，读取:
pr.start()
# 等待pw结束:
pw.join()
# pr进程里是死循环，无法等待其结束，只能强行终止:
pr.terminate()

运行结果如下：

Put A to queue...
Get A from queue.
Put B to queue...
Get B from queue.
Put C to queue...
Get C from queue.