#!/usr/bin/env python2
# coding: utf8
import multiprocessing
def foo(h,context):
if h%2 == 0:
print (h)
else:
context.append(h)
if __name__ == "__main__":
## 设置共享list
con = multiprocessing.Manager().list()
## 设置进程池大小
p = multiprocessing.Pool(2)
for i in range(18):
# con = multiprocessing.Manager().list()
p.apply_async(foo,args=(i,con))
p.close()
p.join()
print con
相关文章
- Python进程学习笔记-多进程修改全局变量
- python--multiprocessing多进程总结
- [b0039] python 归纳 (二四)_多进程数据共享和同步_锁Lock&RLock
- python笔记9 线程进程 threading多线程模块 GIL锁 multiprocessing多进程模块 同步锁Lock 队列queue IO模型
- python 开启进程两种方法 multiprocessing模块 介绍
- python多进程multiprocessing模块中Queue的妙用
- python中多进程multiprocessing、多线程threading、线程池threadpool
- Python--线程队列(queue)、multiprocessing模块(进程对列Queue、管道(pipe)、进程池)、协程
- [b0037] python 归纳 (二二)_多进程数据共享和同步_管道Pipe
- 进程间通信机制(管道、信号、共享内存/信号量/消息队列)、线程间通信机制(互斥锁、条件变量、posix匿名信号量)