• 技术文章 >Python技术 >Python基础教程

    python线程通信Condition提供的方法

    小妮浅浅小妮浅浅2021-09-30 09:38:55原创2698

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

    Lock的acquire()或release()。

    2、wait传入timeout参数。

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

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

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

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

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

    实例

    1

    2

    3

    4

    5

    6

    7

    8

    9

    10

    11

    12

    13

    14

    15

    16

    17

    18

    19

    20

    21

    22

    23

    24

    25

    26

    27

    28

    29

    30

    31

    32

    33

    34

    35

    36

    37

    38

    39

    40

    41

    42

    43

    44

    45

    46

    47

    48

    49

    50

    51

    52

    53

    54

    55

    56

    57

    58

    59

    60

    61

    62

    63

    64

    65

    66

    67

    68

    69

    70

    71

    72

    73

    74

    75

    76

    77

    78

    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学习指路:python基础教程

    本文教程操作环境:windows7系统、Python 3.9.1,DELL G3电脑。

    专题推荐:python线程通信 condition
    上一篇:python线程安全的两种情况 下一篇:python正则表达式问号的使用

    相关文章推荐

    • 进一步认识python线程池• python线程用什么模块好?• Python线程中的阻塞是什么?• python线程中的GIL如何使用?• 如何使用python线程start和run方法?• python线程强制停止工作• python线程中deque如何使用?• python线程优先级队列有哪些?• python线程阻塞的解决• python线程安全的介绍及解决方法• python线程中Condition的原理• python线程事件Event的原理• python线程安全的两种情况

    全部评论我要评论

    © 2021 Python学习网 苏ICP备2021003149号-1

  • 取消发布评论
  • 

    Python学习网