网创优客建站品牌官网
为成都网站建设公司企业提供高品质网站建设
热线:028-86922220
成都专业网站建设公司

定制建站费用3500元

符合中小企业对网站设计、功能常规化式的企业展示型网站建设

成都品牌网站建设

品牌网站建设费用6000元

本套餐主要针对企业品牌型网站、中高端设计、前端互动体验...

成都商城网站建设

商城网站建设费用8000元

商城网站建设因基本功能的需求不同费用上面也有很大的差别...

成都微信网站建设

手机微信网站建站3000元

手机微信网站开发、微信官网、微信商城网站...

建站知识

当前位置:首页 > 建站知识

python线程通信Condition提供的方法有哪些

这篇文章主要介绍“python线程通信Condition提供的方法有哪些”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“python线程通信Condition提供的方法有哪些”文章能帮助大家解决问题。

站在用户的角度思考问题,与客户深入沟通,找到南岳网站设计与南岳网站推广的解决方案,凭借多年的经验,让设计与互联网技术结合,创造个性化、用户体验好的作品,建站类型包括:网站建设、成都网站建设、企业官网、英文网站、手机端网站、网站推广、空间域名、虚拟主机、企业邮箱。业务覆盖南岳地区。

1、acquire调用Condition关联的方法。

Lock的acquire()或release()。

2、wait传入timeout参数。

指定该线程最多等待多少秒。

导致当前线程进入Condition的等待池等待通知并释放锁,直到其他线程调用该Condition的notify()或者notify_all()方法来唤醒该线程。在调用该wait()方法时可以

3、notify唤醒Condition的单个线程并通知。

收到通知的线程会自动调用accquire()方法尝试加锁。如果所有线程都在该Condition等待池中等待,则会选择唤醒其中一个线程,选择是任意性的。

4、notify_all唤醒所有线程并通知。

实例

import threading
class Account:
    # 定义构造函数
    def __init__(self, account_no, balance):
        self.account_no = account_no
        self._balance = balance
        self.condition = threading.Condition()
        # 定义代表是否已经存钱的标识
        self.__deposit_flag = False
 
    # 取钱
    def draw(self, draw_amount):
        # 加锁
        self.condition.acquire()
        try:
            # 还没存钱
            if not self.__deposit_flag:
                self.condition.wait()
            else:
                if self._balance >= draw_amount:
                    self._balance = self._balance - draw_amount
                    print(threading.current_thread().getName() + " 取钱成功,账户余额是:" + str(self._balance) + "\n")
                else:
                    print(threading.current_thread().getName() + " 取钱失败\n")
                # 将标识账户已有存款的标识改成False
                self.__deposit_flag = False
                # 唤醒其他等待现车线程
                self.condition.notify_all()
        finally:
            # 释放锁
            self.condition.release()
 
    # 存钱
    def deposit(self, deposit_amount):
        # 加锁
        self.condition.acquire()
        try:
            # 如果已经存款了,则等待取款
            if self.__deposit_flag:
                self.condition.wait()
            else:
                self._balance = self._balance + deposit_amount
                print(threading.current_thread().getName() + " 存款成功,存款金额是:" + str(deposit_amount) + "\n")
                # 将存款标识改成已存款
                self.__deposit_flag = True
                # 唤醒其他线程
                self.condition.notify_all()
        finally:
            # 释放锁
            self.condition.release()
 
 
def draw_many(account, draw_amount, max):
    for i in range(max):
        account.draw(draw_amount)
 
 
def deposit_many(account, deposit_amount, max):
    for i in range(max):
        account.deposit(deposit_amount)
 
 
# 创建一个账户
account = Account("账户一", 0)
# 创建并启动取钱线程
draw_1 = threading.Thread(name='取钱者一', target=draw_many, args=(account, 200, 50))
draw_1.start()
draw_2 = threading.Thread(name='取钱者二', target=draw_many, args=(account, 200, 50))
draw_2.start()
# 创建并启动存钱线程
deposit_1 = threading.Thread(name='存钱者一', target=deposit_many, args=(account, 200, 50))
deposit_1.start()
deposit_2 = threading.Thread(name='存钱者二', target=deposit_many, args=(account, 200, 50))
deposit_2.start()
draw_1.join()
draw_2.join()
deposit_1.join()
deposit_2.join()

关于“python线程通信Condition提供的方法有哪些”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注创新互联行业资讯频道,小编每天都会为大家更新不同的知识点。


分享题目:python线程通信Condition提供的方法有哪些
链接地址:http://bjjierui.cn/article/gdhied.html

其他资讯