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()

    至此  简单得使用已经结束   

  • 相关阅读:
    [置顶] 强力开刷图论目录(不定期更新)
    强力开刷图论目录(图论再临)
    JQuery实现树的功能doc
    JQuery学习网站
    从相学来看眼神的奥秘
    asp之Repeater
    jquery上传文件
    眼神的心理秘密你了解多少
    jquery表单验证控件,下载地址和使用列子
    保护自己的生存法则:识人看眼神
  • 原文地址:https://www.cnblogs.com/nanyu/p/11394739.html
Copyright © 2011-2022 走看看