Python多进程教程

lock = Lock()

items = ['tango', 'foxtrot', 10]

for item in items:

p = Process(target=printer, args=(item, lock))

p.start()

我们在这里创建了一个简单的用于打印函数，你输入什么，它就输出什么。为了避免线程之间互相壅塞，我们应用Lock对象。代码轮回列表中的三个项并为它们各自都创建一个过程。每一个过程都将调用我们的函数，并且每次遍历到的那一项作为参数传入函数。因为我们如今应用了锁，所以队列中下一?过程将一向壅塞，直到之前的过忱矸⑴锁。

为过程创建日记与为线程创建日记有一些不合。它们存在不合是因为Python的logging包不应用共享锁的过程，是以有可能以来自不合过程的信息作为停止的标记。让我们试着给前面的例子添加根本的日记。代码如下：

import logging 
 
import multiprocessing 
 
from multiprocessing import Process, Lock 
 
def printer(item, lock): 
 
    """ 
 
    Prints out the item that was passed in 
 
    """ 
 
    lock.acquire() 
 
    try: 
 
        print(item) 
 
    finally: 
 
        lock.release() 
 
if __name__ == '__main__': 
 
    lock = Lock() 
 
    items = ['tango', 'foxtrot', 10] 
 
    multiprocessing.log_to_stderr() 
 
    logger = multiprocessing.get_logger() 
 
    logger.setLevel(logging.INFO) 
 
    for item in items: 
 
        p = Process(target=printer, args=(item, lock)) 
 
        p.start()

最简单的添加日记的办法经由过程推送它到stderr实现。我们能经由过程调用thelog_to_stderr() 函数来实现该办法。然后我们调用get_logger 函数获得一个logger实例，并将它的日记等级设为INFO。之后的代码是雷同的。须要提示下这里我并没有调用join()办法。取而代之的：当它退出，父线程将主动调用join()办法。

from multiprocessing import Pool 
 
def doubler(number): 
 	
			 3/6   首页 上一页 1 2 3 4 5 6 下一页 尾页	
			

　　推荐阅读
　　马云说智能世界三要素：互联网、大数据、云计算，机器是不可能取代人类的
            
            我今天不是为不合而不合，我本身认为我们在进入数据时代，一个很重要的事，每小我对每个问题的看法、角度、深度和广度必须是不一样的，只有不一样，你才是你。人工智能，我是这么看的良士>>>详细阅读


本文标题：Python多进程教程
地址：http://www.17bianji.com/lsqh/35977.html
 1/2    1