python多任务的导包问题

Posted 2021-01-06 skaarl

多线程的使用：

　　import threading

　　def func(x):
　　　　print(x)
　　t= threading.Thread(target=func,args=(12,))
　　# 线程启动
　　t.start()
　　# 主进程阻塞，等待子进程的退出
　　t.join()
　   # 设置线程为主线程的守护线程
　　t.setDaemon()

多进程的使用
　　from multiprocessing import Process
　　def func(x):
　　　　print(x)
　　p = Process(target=func,args=(12,))
　　p.start()# 启动子进程实例(创建子进程)
　　p.is_alive()# 判断进程子进程是否还在活着
　　p.join(timeout)# 是否等待子进程执行结束，或者等待多少秒
　　p.terminate()# 不管任务是否完成，立即终止子进程
　　p.daemon = True # 设置守护进程

线程池、进程池的使用：
　　# 进程池
　　from multiprocessing import Pool

　　# 线程池
　　from multiprocessing.dummy import Pool
　　pool = Pool(5) # 同时最大运行线程或者进程个数

　　def _excute(x,y):
　　　　print(x+y)
　　def _callback(self, temp): # temp必有参数
　　　　print("线程或进程任务完成后的回调")

　　pool.apply_async(target=_excute, callback=_callback)
　　poll.close()# 关闭Pool，使其不再接受新的任务；
　　poll.terminate()# 不管任务是否完成，立即终止；
　　poll.join()# 主进程阻塞，等待子进程的退出,必须在close或terminate之后使用

 

进程或者线程的间通信工具--Queue

　　# 线程池、多线程 使用的Queue
　　from queue import Queue

　　# 多进程使用的queue
　　from multiprocessing import JoinableQueue as Queue

　　# 进程池使用的queue
　　from multiprocessing import Manager

　　queue = Manager().Queue()
　　queue = Queue()

　　queue.qsize()# 返回当前队列包含的消息数量。
　　queue.empty()# 如果队列为空，返回True,反之False。
　　queue.full()# 如果队列满了，返回True，反之False。
　　queue.put(item, block=True, timeout=None)

　　将item消息写入队列，block默认值为True；
　　如果block使用默认值，且没有设置timeout（单位秒），消息列队如果已经没有空间可写入，此时程序将被阻塞（停
　　在写入状态），直到从消息列队腾出空间为止，如果设置了timeout，则会等待timeout秒，若还没空间，则抛
　　出"Queue.Full"异常；
　　如果block值为False，消息列队如果没有空间可写入，则会立刻抛出"Queue.Full"异常；

　　
　　queue.get(item, block=True, timeout=None)
　
　　获取队列中的一条消息，然后将其从队列中移除，block默认值为True。如果block使用默认值，且没有设置
　　timeout（单位秒），消息列队如果为空，此时程序将被阻塞（停在读取状态），直到从消息列队读到消息为止，如果
　　设置了timeout，则会等待timeout秒，若还没读取到任何消息，则抛出"Queue.Empty"异常；
　　如果block值为False，消息列队如果为空，则会立刻抛出"Queue.Empty"异常；
　
　　# get方法并不能让queue的计数-1，必须调用task_done
　　queue.task_done()