zoukankan      html  css  js  c++  java
  • python 进程 进程池 进程间通信

    1.python 中创建进程的两种方式:

    from multiprocessing import Process
    import time
    def test_():
        print '-----test-----'
    if __name__ == '__main__':
        p = Process(target=test_)
        p.start()
        while True:
            print '--main--'
            
    
    '''1.通过process 类创建一个进程对象,然后start即可开启进程, test
    test_函数是进程实现的功能'''
     
     from multiprocessing import Process
     import time
     class MyNewProcess(Process):
         def run(self):
             print '------run-------'
     if __name__ == '__main__':
         p = MyNewProcess()
         p.start()
         print '---main-----'
     '''2.通过类似继承process   子类中必须有run 方法 里边实现 进程功能 
     创建对象之后 调用start'''

    2.进程池

    from multiprocessing import Pool
    from time import sleep
    import os
    
    
    def func(num):
        for i in range(3):
            print '%s %s' %(os.getpid(),num) #
            sleep(2)
    
    
    def main():
        pool = Pool(3)
        for i in range(3, 6):
            res = pool.apply_async(func, (i,))
        pool.close()
        pool.join()
    
    
    if __name__ == '__main__':
        main()
    

    3.进程间通信

    '''python 进程间通信     Queue '''
    
    '''1.Queue使用方法
        1.Queue.qsize(): 返回当前队列包含的消息数量
        2.Queue.empty(): 如果队列为空 返回True 反之 False
        3.Queue.full():  如果队列满了返回True 反之 False
        4.Queue.get():   获取队列中一条消息 然后将其从队列中移除 可传参数 超市时长
        Queue.get_nowait(): 相当于 Queue.get(False) 取不到值 触发异常
        Queue.put(): 将一个值添加到数列 可传参数 超时时长
        Queue.put_nowait():相当于 Queue.get(False)  当队列满时 报错
    '''
    
    
    from multiprocessing import Process, Queue
    import time
    
    q = Queue()  # 创建队列
    for i in range(10):
        q.put(i)
        
        
    def test_a():
            try:
                while True:
                    num = q.get_nowait()
                    print '我是进程a 取出数字为:%s'%num
                    time.sleep(1)
            except Exception, e:
                print e
    
    
    def test_b():
        try:
            while True:
                num = q.get_nowait()
                print '我是进程b 取出数字是:%s'%num
                time.sleep(1)
        except Exception, e:
            print e
    
    
    if __name__ == '__main__':
        p1 = Process(target=test_a)
        p2 = Process(target=test_b)
        p1.start()
        p2.start()

    至此  简单得使用已经结束   

  • 相关阅读:
    chmod命令详细用法
    mysql删除sql表添加别名及删除sql的注意事项
    bootstrap栅格系统进行偏移格式
    mysql中时间计算函数SQL DATE_SUB()用法
    阿里图标的应用教程
    jquery.cookie.js中$.cookie() 使用方法
    $.cookie()取值设置
    java中年月日的加减法,年月的加减法使用
    IMAP命令与分析
    Telnet IMAP Commands Note
  • 原文地址:https://www.cnblogs.com/nanyu/p/11394739.html
Copyright © 2011-2022 走看看