本文实例讲述了python mutiprocessing多线程池pool操作。分享给大家供大家参考,具体如下:
python — mutiprocessing 多线程 pool
脚本代码:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
root@ 72132server :~ / python / multiprocess # ls
multiprocess_pool.py multprocess.py
root@ 72132server :~ / python / multiprocess # cat multiprocess_pool.py
#!/usr/bin/python
# --*-- coding:utf-8 --*--
import multiprocessing
import sys,os,time
result = [] #把运行的进程池放入,空的列表
def run(msg): #定义正在处理进程编号数的函数功能
print 'threading number:%s %s' % (msg,os.getpid()) #打印正在处理的进程编号数与对应的系统进程号
time.sleep( 2 )
p = multiprocessing.pool(processes = 25 ) #绑定事例,同时执行25个线程
for i in range ( 100 ):
result.append(p.apply_async(run,( '%s' % i,))) #异步传输正在运行的进程数字号码
p.close() #关闭正在运行的25个进程
#p.join()
for res in result: #获取运行结果
res.get(timeout = 5 )
root@ 72132server :~ / python / multiprocess #
|
运行情况:
1)脚本运行
1
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
46
47
48
49
50
51
52
53
|
root@ 72132server :~ / python / multiprocess # python multiprocess_pool.py
threading number: 0 27912
threading number: 1 27915
threading number: 2 27913
threading number: 3 27916
threading number: 4 27917
threading number: 5 27918
threading number: 6 27919
threading number: 7 27920
threading number: 8 27922
threading number: 9 27923
threading number: 10 27924
threading number: 11 27925
threading number: 12 27926
threading number: 13 27927
threading number: 14 27928
threading number: 15 27914
threading number: 16 27929
threading number: 17 27921
threading number: 18 27930
threading number: 19 27931
threading number: 20 27932
threading number: 21 27934
threading number: 22 27935
threading number: 23 27936
threading number: 24 27933
threading number: 25 27912
threading number: 26 27915
threading number: 27 27917
threading number: 28 27918
threading number: 29 27916
threading number: 30 27913
threading number: 31 27922
threading number: 32 27919
threading number: 33 27920
threading number: 34 27923
threading number: 35 27924
threading number: 36 27925
threading number: 37 27927
threading number: 38 27921
threading number: 39 27930
threading number: 40 27932
threading number: 41 27934
threading number: 42 27935
threading number: 43 27926
threading number: 44 27931
threading number: 45 27928
threading number: 46 27929
threading number: 47 27914
threading number: 48 27933
threading number: 49 27936
threading number: 50 27912
threading number: 51 27915
|
2)进程查看(25个进程同时运行)
1
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
root@ 72132server :~ / python / multiprocess # ps -ef | grep multi
root 27905 23930 0 22 : 39 pts / 3 00 : 00 : 00 grep multi
root@ 72132server :~ / python / multiprocess # ps -ef | grep multi
root 27911 20609 1 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27912 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27913 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27914 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27915 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27916 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27917 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27918 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27919 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27920 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27921 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27922 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27923 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27924 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27925 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27926 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27927 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27928 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27929 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27930 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27931 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27932 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27933 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27934 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27935 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27936 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27941 23930 0 22 : 39 pts / 3 00 : 00 : 00 grep multi
root@ 72132server :~ / python / multiprocess # ps -ef | grep multi
root 27911 20609 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27912 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27913 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27914 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27915 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27916 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27917 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27918 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27919 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27920 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27921 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27922 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27923 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27924 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27925 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27926 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27927 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27928 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27929 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27930 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27931 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27932 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27933 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27934 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27935 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27936 27911 0 22 : 39 pts / 1 00 : 00 : 00 python multiprocess_pool.py
root 27943 23930 0 22 : 39 pts / 3 00 : 00 : 00 grep multi
root@ 72132server :~ / python / multiprocess #
|
希望本文所述对大家python程序设计有所帮助。
原文链接:https://blog.csdn.net/xwbk12/article/details/77624248