python多进程并行代码实例

yipeiwu_com7年前Python基础

这篇文章主要介绍了python多进程并行代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

代码:

from multiprocessing import Process
import sys, os
import time


def timetask(string):
 while True:
  print(string)

def works(func, arg, worknum):
 proc_record = []
 for i in range(worknum):
  p = Process(target = func, args = (i,))
  p.start()
  proc_record.append(p)
 for p in proc_record:
  p.join()

if __name__ == '__main__':
 arg = 5
 procs = 4
 works(timetask, arg, procs)

效果图【未加锁,会发现数字1没出现,进程间资源抢夺导致】:

优化之后效果:

代码:

from multiprocessing import Process
import sys, os
import time
from threading import Lock


def timetask(string):
 mutex.acquire()
 while True:
  print(string)
  if mutex.locked():
   mutex.release()


mutex = Lock()

def works(func, arg, worknum):
 proc_record = []
 for i in range(worknum):
  p = Process(target = func, args = (i,))
  p.start()
  proc_record.append(p)
 for p in proc_record:
  p.join()

if __name__ == '__main__':
 arg = 5
 procs = 4
 works(timetask, arg, procs)

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持【听图阁-专注于Python设计】。

相关文章

python with提前退出遇到的坑与解决方案

问题的起源 早些时候使用with实现了一版全局进程锁,希望实现以下效果: with CacheLock("test_lock", 10): #如果抢占到锁,那么就执行这段代码...

Python 转义字符详细介绍

Python 转义字符 在需要在字符中使用特殊字符时,python用反斜杠(\)转义字符。如下表: 原始字符串 有时我们并不想让转义字符生效,我们只想显示字符串原来的意思,这就要用r和...

Python使用smtplib模块发送电子邮件的流程详解

Python使用smtplib模块发送电子邮件的流程详解

1、登录SMTP服务器 首先使用网上的方法(这里使用163邮箱,smtp.163.com是smtp服务器地址,25为端口号): import smtplib server = smt...

python实现求最长回文子串长度

给定一个字符串,求它最长的回文子串长度,例如输入字符串'35534321',它的最长回文子串是'3553',所以返回4。 最容易想到的办法是枚举出所有的子串,然后一一判断是否为回文串,返...

pyqt 实现为长内容添加滑轮 scrollArea

pyqt 实现为长内容添加滑轮 scrollArea

如果一个页面里头的内容太长,怎么办? 之前一直以为要添加Scroll Bar,但是不知道怎么把bar和内容关联到一起(有了解的朋友希望给我留言),后来发现可以用Scroll Area实现...