我的Python成长之路---第八天---Python基础（25）---2016年3月5日（晴）

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

#!/usr/bin/env python3

# coding:utf-8

‘‘‘

Created on: 2016年3月5日

@author: 张晓宇

Email: [email protected]

Version: 1.0

Description: 多进程演示程序

Help:

‘‘‘

from multiprocessing import Process

import os

def run_proc(name):

    # 子进程要执行的函数

    print(‘Run child process %s (%s)...‘ % (name, os.getpid())) # os.getpid()表示获得当前进程的pid

if __name__==‘__main__‘:

    print(‘Parent process %s.‘ % os.getpid()) # 打印父进程的pid

    p = Process(target=run_proc, args=(‘test‘,)) # 创建进程对象，参数结构和多线程一样

    print(‘Child process will start.‘)

    p.start() # 启动子进程

    p.join() # 阻塞等待子进程执行完毕

    print(‘Child process end.‘)

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

#!/usr/bin/env python3

# coding:utf-8

‘‘‘

Created on: 2016年3月5日

@author: 张晓宇

Email: [email protected]

Version: 1.0

Description: 管道演示程序

Help:

‘‘‘

from multiprocessing import Process, Pipe

def f(conn):

    conn.send([42, None, ‘hello‘]) # 网管道里传递数据

    conn.close()

if __name__ == ‘__main__‘:

    parent_conn, child_conn = Pipe() # 一个是父进程的管道对象，一个是子进程的对象，自己成往里面send，父进程对象recv，有点像socket

    p = Process(target=f, args=(child_conn,)) # 把管道对象作为参数传递给子进程

    p.start()

    print(parent_conn.recv())   # 接收管道里的数据并打印出来

    p.join()

[42, None, ‘hello‘]

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

#!/usr/bin/env python3

# coding:utf-8

‘‘‘

Created on: 2016年3月5日

@author: 张晓宇

Email: [email protected]

Version: 1.0

Description: 管道演示程序

Help:

‘‘‘

from multiprocessing import Process, Pipe

def f(conn, strinfo):

    conn.send([42, None, ‘hello‘]) # 网管道里传递数据

    conn.close() # 关闭管道

    strinfo.append(‘child‘)

if __name__ == ‘__main__‘:

    parent_conn, child_conn = Pipe() # 一个是父进程的管道对象，一个是子进程的对象，自己成往里面send，父进程对象recv，有点像socket

    strinfo = [‘parent‘]

    p = Process(target=f, args=(child_conn, strinfo)) # 把管道对象作为参数传递给子进程

    p.start()

    print(parent_conn.recv())   # 接收管道里的数据并打印出来

    print(strinfo)

    p.join()

2

[42, None, ‘hello‘]

[‘parent‘]

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

#!/usr/bin/env python

# coding:utf-8

‘‘‘

Created on: 2016年3月5日

@author: 张晓宇

Email: [email protected]

Version: 1.0

Description: 进程池演示程序

Help:

‘‘‘

from  multiprocessing import Pool, freeze_support

import time

def Foo(i):

    ‘‘‘

    子进程执行的函数

    :param i:

    :return:

    ‘‘‘

    time.sleep(2)

    return i+100

def Bar(arg):

    ‘‘‘

    子进程回调函数

    :param arg:

    :return:

    ‘‘‘

    print(‘-->exec done:‘,arg)

if __name__ == ‘__main__‘: # 这个在windows环境中绝对不能省略否则会报错

    freeze_support()

    pool = Pool(5) # 创建进程池对象

    for i in range(10):

        pool.apply_async(func=Foo, args=(i,), callback=Bar)

        # pool.apply(func=Foo, args=(i,))

    print(‘end‘)

    pool.close()

    pool.join()#进程池中进程执行完毕后再关闭，如果注释，那么程序直接关闭。

2

3

4

5

6

7

8

9

10

11

end

-->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