Python3 多线程编程 threading模块

Posted 2021-12-13 cai-auto

性能自动化测试除了用jmeter还可以用python threading模块做

一.threading模块定义

Python 2.4中包含的较新的线程模块为线程提供了更强大的高级支持。

线程模块公开线程模块的所有方法，并提供一些额外的方法

activecount()——返回活动的线程对象的数量。

currentthread()——返回调用方线程控件中线程对象的数量。

enumerate()——返回当前活动的所有线程对象的列表。

除了方法之外，线程模块还有实现线程的Thread类实现了hreading。Thread类提供的方法如下-

run() - run()方法是线程的入口点。

start()——start()方法通过调用run方法启动线程。

join([time])——join()等待线程终止。

isAlive()方法检查线程是否仍在执行。

getName()——getName()方法返回线程的名称。

setName()——setName()方法设置线程的名称。

 

二.使用threading模块实现一个新线程

定义Thread类的一个新子类。

覆盖_init__(self [，args])方法来添加额外的参数。

然后，覆盖run(self [，args])方法来实现线程启动时应该执行的操作。

 

一旦创建了新的Thread子类，就可以创建它的一个实例，然后通过调用start()启动一个新线程，start()又调用run()方法。

 

三.实例

import threading
import time

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 ("Starting " + self.name)
      print_time(self.name, self.counter, 5)
      print ("Exiting " + self.name)

def print_time(threadName, delay, counter):
   while counter:
      if exitFlag:
         threadName.exit()
      time.sleep(delay)
      print ("%s: %s" % (threadName, time.ctime(time.time())))
      counter -= 1

# Create new threads
thread1 = myThread(1, "Thread-1", 1)
thread2 = myThread(2, "Thread-2", 2)

# Start new Threads
thread1.start()
thread2.start()
thread1.join()
thread2.join()
print ("Exiting Main Thread")

执行结果

Starting Thread-1
Starting Thread-2
Thread-1: Fri Feb 19 10:00:21 2016
Thread-2: Fri Feb 19 10:00:22 2016
Thread-1: Fri Feb 19 10:00:22 2016
Thread-1: Fri Feb 19 10:00:23 2016
Thread-2: Fri Feb 19 10:00:24 2016
Thread-1: Fri Feb 19 10:00:24 2016
Thread-1: Fri Feb 19 10:00:25 2016
Exiting Thread-1
Thread-2: Fri Feb 19 10:00:26 2016
Thread-2: Fri Feb 19 10:00:28 2016
Thread-2: Fri Feb 19 10:00:30 2016
Exiting Thread-2
Exiting Main Thread