文章详情

登录

短信预约-IT技能 免费直播动态提醒

选择考试省份

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团

请输入下面的图形验证码

提交验证

短信预约提醒成功

python中的多进程处理

2023-01-31 01:49

关注
  众所周知，python本身是单线程的，python中的线程处理是由python解释器分配时间片的；但在python 3.0中吸收了开源模块，开始支持系统原生的进程处理——multiprocessing.

注意：这个模块的某些函数需要操作系统的支持，例如，multiprocessing.synchronize模块在某些平台上引入时会激发一个ImportError

1)Process
  要创建一个Process是很简单的。
  1. from multiprocessing import Process
  3. def f(name):
  4.     print('hello', name)
  6. if __name__ == '__main__':
  7.      p = Process(target=f, args=('bob',))
  8.      p.start()
  9.      p.join()
  要获得一个Process的进程ID也是很简单的。
  1. from multiprocessing import Process
  2. import os
  4. def info(title):
  5.     print title
  6.     print 'module name:', __name__
  7.     print 'parent process:', os.getppid()#这个测试不通过，3.0不支持
  8.     print 'process id:', os.getpid()
  10. def f(name):
  11.     info('function f')
  12.     print 'hello', name
  14. if __name__ == '__main__':
  15.     info('main line')
  16.     p = Process(target=f, args=('bob',))
  17.     p.start()
  18.     p.join()
  创建进程：multiprocessing.Process([group[, target[, name[, args[, kargs]]]]])
  参数：
  group:    None,它的存在仅仅是为了与threading.Thread兼容
  target:   一般是函数
  name:     进程名
  args:     函数的参数
  kargs:    keywords参数

  函数：
  run()                  默认的run()函数调用target的函数，你也可以在子类中覆盖该函数
  start()                启动该进程
  join([timeout])        父进程被停止，直到子进程被执行完毕。
                         当timeout为None时没有超时，否则有超时。
                         进程可以被join很多次，但不能join自己
  is_alive()            
  terminate()            结束进程。
                         在Unix上使用的是SIGTERM
                         在Windows平台上使用TerminateProcess

  属性：
  name                   进程名
  daemon                 守护进程
  pid                    进程ID
  exitcode               如果进程还没有结束，该值为None
  authkey                   
           
2)Queue
  Queue类似于queue.Queue，一般用来进程间交互信息
  例子：
  1. from multiprocessing import Process, Queue
  3. def f(q):
  4.     q.put([42, None, 'hello'])
  6.  if __name__ == '__main__':
  7.      q = Queue()
  8.      p = Process(target=f, args=(q,))
  9.      p.start()
  10.      print(q.get())    # prints "[42, None, 'hello']"
  11.      p.join()
  注意：Queue是进程和线程安全的。
  Queue实现了queue.Queue的大部分方法，但task_done()和join()没有实现。   
  创建Queue:multiprocessing.Queue([maxsize])
  函数：
  qsize()                             返回Queue的大小
  empty()                             返回一个boolean值表示Queue是否为空
  full()                              返回一个boolean值表示Queue是否满
  put(item[, block[, timeout]])      
  put_nowait(item)
  get([block[, timeout]])
  get_nowait()
  get_no_wait()

  close()                             表示该Queue不在加入新的元素
  join_thread()                      
  cancel_join_thread()

3)JoinableQueue
  创建：multiprocessing.JoinableQueue([maxsize])
  task_done()
  join()

4)Pipe
  1. from multiprocessing import Process, Pipe
  3. def f(conn):
  4.     conn.send([42, None, 'hello'])
  5.     conn.close()
  7. if __name__ == '__main__':
  8.     parent_conn, child_conn = Pipe()
  9.     p = Process(target=f, args=(child_conn,))
  10.     p.start()
  11.     print(parent_conn.recv())   # prints "[42, None, 'hello']"
  12.     p.join()
  multiprocessing.Pipe([duplex])      返回一个Connection对象

5)异步化synchronization

  1. from multiprocessing import Process, Lock
  3. def f(l, i):
  4.     l.acquire()
  5.     print('hello world', i)
  6.     l.release()
  8. if __name__ == '__main__':
  9.     lock = Lock()
  11.     for num in range(10):
  12.         Process(target=f, args=(lock, num)).start()
6)Shared Memory
  1. from multiprocessing import Process, Value, Array
  3. def f(n, a):
  4.     n.value = 3.1415927
  5.     for i in range(len(a)):
  6.         a[i] = -a[i]
  8. if __name__ == '__main__':
  9.     num = Value('d', 0.0)
  10.     arr = Array('i', range(10))
  12.     p = Process(target=f, args=(num, arr))
  13.     p.start()
  14.     p.join()
  16.     print(num.value)
  17.     print(arr[:])
1>Value
2>Array

7)Manager
  1. from multiprocessing import Process, Manager
  3. def f(d, l):
  4.     d[1] = '1'
  5.     d['2'] = 2
  6.     d[0.25] = None
  7.     l.reverse()
  9. if __name__ == '__main__':
  10.     manager = Manager()
  12.     d = manager.dict()
  13.     l = manager.list(range(10))
  15.     p = Process(target=f, args=(d, l))
  16.     p.start()
  17.     p.join()
  19.     print(d)
  20.     print(l)

8)Pool
  1. from multiprocessing import Pool
  3. def f(x):
  4.     return x*x
  6. if __name__ == '__main__':
  7.     pool = Pool(processes=4)              # start 4 worker processes
  8.     result = pool.apply_async(f, [10])     # evaluate "f(10)" asynchronously
  9.     print result.get(timeout=1)           # prints "100" unless your computer is *very* slow
  10.     print pool.map(f, range(10))          # prints "[0, 1, 4,..., 81]"
multiprocessing.Pool([processes[, initializer[, initargs]]])

函数：
  apply(func[, args[, kwds]])
  apply_async(func[, args[, kwds[, callback]]])
  map(func,iterable[, chunksize])
  map_async(func,iterable[, chunksize[, callback]])
  imap(func, iterable[, chunksize])
  imap_unordered(func, iterable[, chunksize])
  close()
  terminate()
  join()

  1. from multiprocessing import Pool
  3. def f(x):
  4.     return x*x
  6. if __name__ == '__main__':
  7.     pool = Pool(processes=4)              # start 4 worker processes
  9.     result = pool.apply_async(f, (10,))   # evaluate "f(10)" asynchronously
  10.     print(result.get(timeout=1))          # prints "100" unless your computer is *very* slow
  12.     print(pool.map(f, range(10)))         # prints "[0, 1, 4,..., 81]"
  14.     it = pool.imap(f, range(10))
  15.     print(next(it))                       # prints "0"
  16.     print(next(it))                       # prints "1"
  17.     print(it.next(timeout=1))             # prints "4" unless your computer is *very* slow
  19.     import time
  20.     result = pool.apply_async(time.sleep, (10,))
  21.     print(result.get(timeout=1))          # raises TimeoutError
   

9)杂项
multiprocessing.active_children()          返回所有活动子进程的列表
multiprocessing.cpu_count()                返回CPU数目
multiprocessing.current_process()          返回当前进程对应的Process对象
multiprocessing.freeze_support()
multiprocessing.set_executable()

10)Connection对象
send(obj)
recv()
fileno()
close()
poll([timeout])
send_bytes(buffer[, offset[, size]])
recv_bytes([maxlength])
recv_bytes_info(buffer[, offset]) 
  1. >>> from multiprocessing import Pipe
  2. >>> a, b = Pipe()
  3. >>> a.send([1, 'hello', None])
  4. >>> b.recv()
  5. [1, 'hello', None]
  6. >>> b.send_bytes('thank you')
  7. >>> a.recv_bytes()
  8. 'thank you'
  9. >>> import array
  10. >>> arr1 = array.array('i', range(5))
  11. >>> arr2 = array.array('i', [0] * 10)
  12. >>> a.send_bytes(arr1)
  13. >>> count = b.recv_bytes_into(arr2)
  14. >>> assert count == len(arr1) * arr1.itemsize
  15. >>> arr2
  16. array('i', [0, 1, 2, 3, 4, 0, 0, 0, 0, 0])

阅读原文内容投诉

免责声明：

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题

  • 2024年上半年信息系统项目管理师第二批次真题及答案解析（完整版）

    难度     813人已做
    查看

  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看

  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看

  • 2024年上半年软考高项第一、二批次真题考点汇总（完整版）

    难度     435人已做
    查看

  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机

python中的多进程处理

后端开发2023-01-31

Python中多线程和多处理的分析

后端开发2023-06-16

在 Python 中利用Pool 进行多处理

后端开发2024-04-02

如何在Python中实现多线程和多进程的实时接口和文件处理？

后端开发2023-08-20

Python多线程、多进程详细整理

后端开发Python多线程2024-12-02

用python3的多进程和协程处理MyS

后端开发2023-01-31

Python中多处理与多线程的区别是什么

后端开发2023-06-16

Python中多线程和多处理的指南是怎样的

后端开发2023-06-05

python 多线程处理List

后端开发2023-01-31

Python开发注意事项：处理多线程和多进程时的注意事项

Python开发注意事项：处理多线程和多进程时的注意事项
后端开发2023-11-22

如何在PHP开发中处理多线程和进程管理？

如何在PHP开发中处理多线程和进程管理？
后端开发2023-11-03

深入理解python多进程编程

后端开发2022-06-04

深入浅析python中的多进程、多线程、协程

后端开发2022-06-04

python中多进程和多线程的使用方法

后端开发2023-06-14

Node.js中的进程与子进程怎么处理

后端开发2023-07-04

python多进程multiprocessing的原理和应用

后端开发2023-06-20

python多进程

后端开发2023-01-31

Python -- 多进程

后端开发2023-01-31

Nodejs怎么进行多线程处理

后端开发2023-06-15

Python 多进程

后端开发2023-01-31
位置：首页-资讯-后端开发
咦！没有更多了？去看看其它编程学习网 内容吧
首页课程
资料下载问答资讯