search

使用python3中的threading模块进行简单的并行计算

首先将需要干的事情封装成一个threading类

  • 在__int_构造函数中初始化threading类，同时给私有变量赋值

  • run方法定义线程需要干的事情，当然干的事情也可以封装在当前类之中;获取使用全局的方法；我这里是在类中进行方法的定义

exitflag=0
class myThread(threading.Thread):
  def __init__(self,threadID,name,counter):
    threading.Thread.__init__(self)
    self.threadID=threadID
    self.name=name
    self.counter=counter

  def run(self):
    print("线程开始"+self.  name)
    self.print_time(5)
    print("退出线程"+self.name)

  def print_time(self,delay):
    while self.counter:
      if exitflag:
        self.name.exit()
      time.sleep(delay)
      print("%s: %s\t%s" %(self.name,self.counter,time.ctime(time.time())))
      print("活跃的线程数为:%s" %(threading.active_count()))
      self.counter-=1

构造threading对象

  • threading类中已经为我们封装好了几个方法，可以直接使用

    • start方法，将会开始一个线程；相当于执行对象中定义好的run方法；

    • join方法会阻塞主线程的运行；相当于主线程开辟两个子线程之后就停下来等待子线程运行结束

  • threading模块中还存在一些只有threading类的方法

    • threading.currentThread(): 返回当前的线程变量。

    • threading.enumerate(): 返回一个包含正在运行的线程的list。正在运行指线程启动后、结束前，不包括启动前和终止后的线程。

    • threading.activeCount(): 返回正在运行的线程数量，与len(threading.enumerate())有相同的结果。

最终程序的运行结果

流程图大概就是这样子的

Previous04.forthClassNexttest

Last updated