在Python中创建进程有两种方式，第一种是：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
from multiprocessing import Process
import time
def test():
while True:
print('---test---')
time.sleep(1)
if __name__ == '__main__':
p=Process(target=test)
p.start()
while True:
print('---main---')
time.sleep(1)
|
上面这段代码是在windows下跑的，通过Process类可以创建一个进程对象，然后p.start()即可开启进程，test函数是你想进程实现的功能。
第二种方式是：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
from multiprocessing import Process
import time
class MyNewProcess(Process):
def run(self):
while True:
print('---1---')
time.sleep(1)
if __name__=='__mian__':
p = MyNewProcess()
# 调用p.start()方法，p会先去父类中寻找start()，然后在Process的start方法中调用run方法
p.start()
while True:
print('---Main---')
time.sleep(1)
|
这里是第二种创建进程的方式，通过子类继承Process类，子类中必须有run方法，里面实现进程功能，创建子类对象之后，调用对象的start方法。
下面来说一下进程池，就是实现已经创建好的进程
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
# 进程池
from multiprocessing import Pool
import os
import random
import time
def worker(num):
for i in range(5):
print('===pid=%d==num=%d='%(os.getpid(),num))
time.sleep(1)
# 3表示进程池中最多有三个进程一起执行
pool=Pool(3)
for i in range(10):
print('---%d---'%i)
# 向进程中添加任务
# 注意：如果添加的任务数量超过了进程池中进程的个数的话，那么就不会接着往进程池中添加，如果还没有执行的话，他会等待前面的进程结束，然后在往
# 进程池中添加新进程
pool.apply_async(worker,(i,))
pool.close() # 关闭进程池
pool.join() # 主进程在这里等待，只有子进程全部结束之后，在会开启主线程
|
大家可以看到在Pool方法就是创建了一个进程池，3表示创建进程数，通过pool.apply_async( )将子进程添加到进程池中，pool.close( )表示关闭进程池，一定要添加join函数，否则主进程直接崩了，看不到进程池中子进程的现象。
以上这篇对Python中创建进程的两种方式以及进程池详解就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持服务器之家。
原文链接：https://blog.csdn.net/u012193416/article/details/78396814