Python中使用Queue和Condition进行线程同步的方法
Queue模块保持线程同步
利用Queue对象先进先出的特性，将每个生产者的数据一次存入队列，而每个消费者将依次从队列中取出数据
import threading # 导入threading模块
import Queue # 导入Queue模块
class Producer(threading.Thread):# 定义生产者类
def __init__(self,threadname):
threading.Thread.__init__(self,name = threadname)
def run(self):
global queue # 声明queue为全局变量
queue.put(self.getName()) # 调用put方法将线程名添加到队列中
print self.getName(),'put ',self.getName(),' to queue'
class Consumer(threading.Thread):# 定义消费者类
def __init__(self,threadname):
threading.Thread.__init__(self,name = threadname)
def run(self):
global queue
print self.getName(),'get ',queue.get(),'from queue'#调用get方法获取队列中内容
queue = Queue.Queue() # 生成队列对象
plist = [] # 生成者对象列表
clist = [] # 消费者对象列表
for i in range(10):
p = Producer('Producer' + str(i))
plist.append(p) # 添加到生产者对象列表
for i in range(10):
c = Consumer('Consumer' + str(i))
clist.append(c) # 添加到消费者对象列表
for i in plist:
i.start() # 运行生产者线程
i.join()
for i in clist:
i.start() # 运行消费者线程
i.join()
######运行结果######
>>> Producer0 put Producer0 to queue
Producer1 put Producer1 to queue
Producer2 put Producer2 to queue
Producer3 put Producer3 to queue
Producer4 put Producer4 to queue
Producer5 put Producer5 to queue
Producer6 put Producer6 to queue
Producer7 put Producer7 to queue
Producer8 put Producer8 to queue
Producer9 put Producer9 to queue
Consumer0 get Producer0 from queue
Consumer1 get Producer1 from queue
Consumer2 get Producer2 from queue
Consumer3 get Producer3 from queue
Consumer4 get Producer4 from queue
Consumer5 get Producer5 from queue
Consumer6 get Producer6 from queue
Consumer7 get Producer7 from queue
Consumer8 get Producer8 from queue
Consumer9 get Producer9 from queue
Condition实现复杂的同步
使用Condition对象可以在某些事件触发或者达到特定的条件后才处理数据，Condition除了具有Lock对象的acquire方法和release方法外，
还有wait方法，notify方法，notifyAll方法等用于条件处理。
条件变量保持线程同步：threading.Condition()
- wait():线程挂起，直到收到一个notify通知才会被唤醒继续运行
- notify():通知其他线程，那些挂起的线程接到这个通知之后会开始运行
- notifyAll(): 如果wait状态线程比较多，notifyAll的作用就是通知所有线程（这个一般用得少）
#coding:utf-8
import threading
import time
cond = threading.Condition()
class kongbaige(threading.Thread):
def __init__(self, cond, diaosiname):
threading.Thread.__init__(self, name = diaosiname)
self.cond = cond
def run(self):
self.cond.acquire() #获取锁
print self.getName() + ':一支穿云箭' #空白哥说的第一句话
self.cond.notify() #唤醒其他wait状态的线程(通知西米哥 让他说话)
#然后进入wait线程挂起状态等待notify通知(等西米哥的回复，接下来俩人就开始扯蛋)
self.cond.wait()
print self.getName() + ':山无棱，天地合，乃敢与君绝!'
self.cond.notify()
self.cond.wait()
print self.getName() + ':紫薇！！！！(此处图片省略)'
self.cond.notify()
self.cond.wait()
print self.getName() + ':是你'
self.cond.notify()
self.cond.wait()
#这里是空白哥说的最后一段话，接下来就没有对白了
print self.getName() + ':有钱吗 借点'
self.cond.notify() #通知西米哥
self.cond.release() #释放锁
class ximige(threading.Thread):
def __init__(self, cond, diaosiname):
threading.Thread.__init__(self, name = diaosiname)
self.cond = cond
def run(self):
self.cond.acquire()
self.cond.wait() #线程挂起(等西米哥的notify通知)
print self.getName() +':千军万马来相见'
self.cond.notify() #说完话了notify空白哥wait的线程
self.cond.wait() #线程挂起等待空白哥的notify通知
print self.getName() + ':海可枯，石可烂，激情永不散！'
self.cond.notify()
self.cond.wait()
print self.getName() + ':尔康！！！(此处图片省略)'
self.cond.notify()
self.cond.wait()
print self.getName() + ':是我'
self.cond.notify()
self.cond.wait()
#这里是最后一段话，后面空白哥没接话了 所以说完就释放锁 结束线程
print self.getName() + ':滚'
self.cond.release()
kongbai = kongbaige(cond, ' ')
ximi = ximige(cond, '西米')
#尼玛下面这2个启动标志是关键，虽然是空白哥先开的口，但是不能让他先启动，
#因为他先启动的可能直到发完notify通知了，西米哥才开始启动，
#西米哥启动后会一直处于44行的wait状态，因为空白哥已经发完notify通知了进入wait状态了，
#而西米哥没收到
#造成的结果就是2根线程就一直在那挂起，什么都不干，也不扯蛋了
ximi.start()
kongbai.start()
######运行结果######
:一支穿云箭 西米:千军万马来相见 :山无棱，天地合，乃敢与君绝! 西米:海可枯，石可烂，激情永不散！ :紫薇！！！！(此处图片省略) 西米:尔康！！！(此处图片省略) :是你 西米:是我 :有钱吗 借点 西米:滚
Hot AI Tools
Undresser.AI Undress
AI-powered app for creating realistic nude photos
AI Clothes Remover
Online AI tool for removing clothes from photos.
Undress AI Tool
Undress images for free
Clothoff.io
AI clothes remover
Video Face Swap
Swap faces in any video effortlessly with our completely free AI face swap tool!
Hot Article
Hot Tools
Notepad++7.3.1
Easy-to-use and free code editor
SublimeText3 Chinese version
Chinese version, very easy to use
Zend Studio 13.0.1
Powerful PHP integrated development environment
Dreamweaver CS6
Visual web development tools
SublimeText3 Mac version
God-level code editing software (SublimeText3)
Hot Topics
1386
52
How to run programs in terminal vscode
Apr 15, 2025 pm 06:42 PM
In VS Code, you can run the program in the terminal through the following steps: Prepare the code and open the integrated terminal to ensure that the code directory is consistent with the terminal working directory. Select the run command according to the programming language (such as Python's python your_file_name.py) to check whether it runs successfully and resolve errors. Use the debugger to improve debugging efficiency.
Can visual studio code be used in python
Apr 15, 2025 pm 08:18 PM
VS Code can be used to write Python and provides many features that make it an ideal tool for developing Python applications. It allows users to: install Python extensions to get functions such as code completion, syntax highlighting, and debugging. Use the debugger to track code step by step, find and fix errors. Integrate Git for version control. Use code formatting tools to maintain code consistency. Use the Linting tool to spot potential problems ahead of time.
Is the vscode extension malicious?
Apr 15, 2025 pm 07:57 PM
VS Code extensions pose malicious risks, such as hiding malicious code, exploiting vulnerabilities, and masturbating as legitimate extensions. Methods to identify malicious extensions include: checking publishers, reading comments, checking code, and installing with caution. Security measures also include: security awareness, good habits, regular updates and antivirus software.
Can vs code run in Windows 8
Apr 15, 2025 pm 07:24 PM
VS Code can run on Windows 8, but the experience may not be great. First make sure the system has been updated to the latest patch, then download the VS Code installation package that matches the system architecture and install it as prompted. After installation, be aware that some extensions may be incompatible with Windows 8 and need to look for alternative extensions or use newer Windows systems in a virtual machine. Install the necessary extensions to check whether they work properly. Although VS Code is feasible on Windows 8, it is recommended to upgrade to a newer Windows system for a better development experience and security.
Python: Automation, Scripting, and Task Management
Apr 16, 2025 am 12:14 AM
Python excels in automation, scripting, and task management. 1) Automation: File backup is realized through standard libraries such as os and shutil. 2) Script writing: Use the psutil library to monitor system resources. 3) Task management: Use the schedule library to schedule tasks. Python's ease of use and rich library support makes it the preferred tool in these areas.
What is vscode What is vscode for?
Apr 15, 2025 pm 06:45 PM
VS Code is the full name Visual Studio Code, which is a free and open source cross-platform code editor and development environment developed by Microsoft. It supports a wide range of programming languages and provides syntax highlighting, code automatic completion, code snippets and smart prompts to improve development efficiency. Through a rich extension ecosystem, users can add extensions to specific needs and languages, such as debuggers, code formatting tools, and Git integrations. VS Code also includes an intuitive debugger that helps quickly find and resolve bugs in your code.
Can visual studio code run python
Apr 15, 2025 pm 08:00 PM
VS Code not only can run Python, but also provides powerful functions, including: automatically identifying Python files after installing Python extensions, providing functions such as code completion, syntax highlighting, and debugging. Relying on the installed Python environment, extensions act as bridge connection editing and Python environment. The debugging functions include setting breakpoints, step-by-step debugging, viewing variable values, and improving debugging efficiency. The integrated terminal supports running complex commands such as unit testing and package management. Supports extended configuration and enhances features such as code formatting, analysis and version control.
Can vs code run python
Apr 15, 2025 pm 08:21 PM
Yes, VS Code can run Python code. To run Python efficiently in VS Code, complete the following steps: Install the Python interpreter and configure environment variables. Install the Python extension in VS Code. Run Python code in VS Code's terminal via the command line. Use VS Code's debugging capabilities and code formatting to improve development efficiency. Adopt good programming habits and use performance analysis tools to optimize code performance.
