无业可守 创新图强
living innovation

月博会员登录入口

当前位置:首页 > 月博会员登录入口 >

python多任务的导包问题

日期:2019-08-18

多线程的使用:

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