Python3——多线程之threading模块_python3.11 threading

                         Python3——多线程之threading模块

目录

Python3——多线程之threading模块

Threading模块的对象

Threading模块的Thread类

queue模块（线程间通信）

---

Python 提供了多个模块来支持多线程编程，包括 thread、 threading 和 Queue 模块等。程序是可以使用 thread 和 threading 模块来创建与管理线程。 thread 模块提供了基本的线程和锁定支持；而 threading 模块提供了更高级别、功能更全面的线程管理。使用 Queue 模块，用户可以创建一个队列数据结构，用于在多线程之间进行共享。（推荐使用threading模块比thread模块更高级）

 

• Threading模块的对象

 

• Threading模块的Thread类

import threading
from time import ctime, sleep
 
loops = (3, 2)
 
class Mythread(threading.Thread):
	def __init__(self, func, args, name=''):
		threading.Thread.__init__(self)
		self.name = name
		self.func = func
		self.args = args
		
	''' rewrite run() '''
	def run(self):
		self.func(*self.args)
 
''' thread handle func --- while(1) '''
def loop(nloop, nsec):
	while True:
		print('start loop ' + str(nloop), 'at: ' + str(ctime()))
		sleep(nsec)
	
def main():
	threads = []
	nloops = range(len(loops))
	
	for i in nloops:
		t = Mythread(loop, (i + 1, loops[i]), loop.__name__)
		threads.append(t)
	
	for i in nloops:
		threads[i].start()
	
	
if __name__ == '__main__':
	main()

• queue模块（线程间通信）

import threading
from random import randint
from queue import *
from time import ctime, sleep
 
class Mythread(threading.Thread):
	def __init__(self, func, name=''):
		threading.Thread.__init__(self)
		self.name = name
		self.func = func
		
	''' rewrite run() '''
	def run(self):
		self.func()
 
class MyQueue():	
	def __init__(self, q, loops):
		self.q = q
		self.loops = loops
	
	def WriteQueue(self):
		self.q.put('xxx', 1)
 
	def ReadQueue(self):
		value = self.q.get(1)
		print('value: ' + str(value))
		return value
		
	def Writer(self):
		while 1:
			for i in range(self.loops):
				self.WriteQueue()
 
	def Reader(self):
		while 1:
			for i in range(self.loops):
				aaa = self.ReadQueue()
				print("aaa = " + str(aaa))
	
def main():
	que = Queue(32)
	nloops = randint(2, 5)
	q = MyQueue(que, nloops)
 
	t1 = Mythread(q.Writer, q.Writer.__name__)
 
	t2 = Mythread(q.Reader, q.Reader.__name__)
	
	t1.start()
	t2.start()
 
if __name__ == '__main__':
	main()