#!/usr/bin/env python3
# coding: utf-8
import multiprocessing
import time
import datetime
def executor(lock, test_list, test_value, e_id):
time.sleep(1)
try:
lock.acquire()
test_list.append(e_id)
test_value.value += 1
except Exception as e:
print(e)
raise e
finally:
lock.release()
print(f"executor id: {e_id}, test_list: {test_list}, time: {datetime.datetime.now()}")
def main():
pool = multiprocessing.Pool(processes=4)
manager = multiprocessing.Manager()
lock = manager.Lock()
test_list = manager.list()
test_value = manager.Value(int, 0)
for i in range(20):
pool.apply_async(executor, args=(lock, test_list, test_value, i))
pool.close()
pool.join()
test_list.sort()
print(f"test_list: {test_list}")
print(f"test_value: {test_value.value}")
if __name__ == '__main__':
main()
Python 进程池使用示例
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
推荐阅读更多精彩内容
- 当需要创建的子进程数量不多时，可以直接利用multiprocessing中的Process动态成生多个进程，但如果...
- 首先， 进程池的作用就是减少进程的创建和释放 开销的， 所以在类中作为局部变量是不合适的; 其次， 进程池必须在i...
