zoukankan      html  css  js  c++  java
  • 面向对象的多次调用线程(含参版)

    代码:

     import threading

    import queue

    #消费者与生产者模式去实现我们可重复利用的线程
    #主线程为生产者,子线程为消费者

    class Mythread(threading.Thread):
    def __init__(self):
    super().__init__()
    self.q = queue.Queue()
    self.daemon = True #设置守护线程,主线程结束,子线程接着结束
    self.start()
    def run(self): #run里面的东西是在我们的子进程里面去执行,且只有run是在子进程里面
    while True:
    func,args,kwargs = self.q.get() #拿任务
    func(*args,**kwargs) #执行任务
    self.q.task_done()

    def pro(self,func,args = (),kwargs = {}): #定义生产者函数
    self.q.put((func,args,kwargs))

    def join(self):
    self.q.join() #阻塞,直到计数器为0

    def func1(*args,**kwargs):
    print("一",args,kwargs)
    def func2(*args,**kwargs):
    print("二",args,kwargs)
    t = Mythread()
    # t.start() #可以写在类定义的init函数中,省去这一步
    t.pro(func1,args = (1,2,3),kwargs={"name":"A","age":15})
    t.pro(func2,(2,3),{"name":"B","age":14})
    t.join()
    print("结束 ")

    图例:

       

     

  • 相关阅读:
    hdfs校验和
    hdfs读写策略
    hdfs架构
    hdfs数据块
    元数据
    集群的创建
    jQuery_DOM操作
    jQuery_简介_选择器
    Ajax
    MySQL整理_2_数据库操作
  • 原文地址:https://www.cnblogs.com/cxhzy/p/10002022.html
Copyright © 2011-2022 走看看