多进程，进程池。

1.多进程的调用

1.1 multiprocessing调用

from multiprocessing import Process
import time
def f(name):
    time.sleep(1)
    print('hello', name,time.ctime())

if __name__ == '__main__':
    p_list=[]
    for i in range(3):
        p = Process(target=f, args=('alvin',))
        p_list.append(p)
        p.start()
    for i in p_list:
        i.join()
    print('end')

运用for循环开启了3个子进程，全都join在主进程中。运行结果：

hello alvin Tue Oct 18 15:10:28 2016
hello alvin Tue Oct 18 15:10:28 2016
hello alvin Tue Oct 18 15:10:28 2016
end

结果显示：三个字符串同时打印出来。达到了多进程的目的。

1.2类来调用

from multiprocessing import Process
import time

class MyProcess(Process):
    def __init__(self):
        super(MyProcess, self).__init__()
        # self.name = name

    def run(self):
        time.sleep(1)
        print ('hello', self.name,time.ctime())


if __name__ == '__main__':
    p_list=[]
    for i in range(3):
        p = MyProcess()
        p.start()
        p_list.append(p)

    for p in p_list:
        p.join()

    print('end')

同时开启了4个进程，但是并没有直接p.run()指令，但是结果显示：

hello MyProcess-1 Tue Oct 18 15:13:46 2016
hello MyProcess-2 Tue Oct 18 15:13:46 2016
hello MyProcess-3 Tue Oct 18 15:13:46 2016
end

可以看出：run函数是被自动执行的。self.name因为是被默认为进程的名称。

小总结：1.上述的四个进程在执行的过程中实现了真正的并发。但是在多过CPU个数的时候。。。

　　　　2.子进程的创建时将主进程完全copy一遍，很占资源的一种形式。

小细节：win系统中，创建子进程必须加main来标识主，子进程的不同。上述的例子中print（end）若是不在main中会产生影响。

2.进程之间的关系

from multiprocessing import Process
import os
import time
def info(title):
    print(title)
    print('module name:', __name__)
    print('parent process:', os.getppid())
    print('process id:', os.getpid())


def f(name):
    info('33[31;1mfunction f33[0m')
    print('hello', name)

if __name__ == '__main__':
    info('33[32;1mmain process line33[0m')
    time.sleep(5)
    p = Process(target=info, args=('bob',))
    p.start()
    p.join()

上述的代码中展示了进程的father进程的ID和自身的ID （通过os模块的getppid和getppid）

main process line
module name: __main__
parent process: 11156
process id: 4592
bob
module name: __mp_main__
parent process: 4592
process id: 7280

结果表明：主进程的名字为main，并且父进程为pycharm的pid。子进程的name不为main所以不会执行main中内容。

3.进程池

from  multiprocessing import Process, Pool
import time

def Foo(i):
    time.sleep(2)
    return i + 100


def Bar(arg):
    print('-->exec done:', arg)

if __name__ == '__main__':

    pool = Pool(5)

    for i in range(10):
        pool.apply_async(func=Foo, args=(i,), callback=Bar) # 回调函数 每次运行完执行。bar的参数是foo的返回值。、
        # pool.apply(func=Foo, args=(i,))
    pool.close()
    pool.join()
22　　　print('end')

执行结果：没隔2秒钟出现5个执行结果

-->exec done: 100
-->exec done: 101
-->exec done: 102
-->exec done: 103
-->exec done: 104
-->exec done: 105
-->exec done: 106
-->exec done: 107
-->exec done: 108
-->exec done: 109
end