threading - 标记值或事件来打破循环

Question

我可以想到两种方法来打破 Python 线程中的循环，下面是最小的示例：

1 - 使用标记值

from threading import Thread, Event
from time import sleep

class SimpleClass():

    def do_something(self):
        while self.sentinel:
            sleep(1)
            print('loop completed')

    def start_thread(self):
        self.sentinel = True
        self.th = Thread(target=self.do_something)
        self.th.start()

    def stop_thread(self):
        self.sentinel = False
        self.th.join()

simpleinstance = SimpleClass()
simpleinstance.start_thread()
sleep(5)
simpleinstance.stop_thread()

2 - 使用事件

from threading import Thread, Event
from time import sleep

class SimpleThread(Thread):

    def __init__(self):
        super(SimpleThread, self).__init__()

        self.stoprequest = Event()

    def run(self):
        while not self.stoprequest.isSet():
            sleep(1)
            print('loop completed')

    def join(self, timeout=None):
        self.stoprequest.set()
        super(SimpleThread, self).join(timeout)

simpleinstance = SimpleThread()
simpleinstance.start()
sleep(5)
simpleinstance.join()

在 Python 文档中，它讨论了事件，但没有讨论更简单的 'sentinel value' 方法（我看到它在 Stack Overflow 上的许多线程答案中使用）。

使用标记值有什么缺点吗？

具体来说，它会导致错误吗（我从来没有遇到过错误，但我想如果你试图在 while 循环读取它的同一时刻更改哨兵的值，那么某些东西可能会中断（或者也许在这种情况下，CPython GIL 会救我。什么是最佳（最安全）实践？

Answer 1

如果您查看 Event 的源代码，您会发现您正在使用的函数对您没有任何价值：

class Event:
    def __init__(self):
        self._cond = Condition(Lock())
        self._flag = False

    def is_set(self):
        return self._flag

    def set(self):
        with self._cond:
            self._flag = True
            self._cond.notify_all() # No more-value, because you are not using Event.wait

所以在你的情况下 Event 只是一个没有实际使用的哨兵值的花哨包装器，这也会减慢你的操作时间 really 微小金额。

事件只有在您使用它们的 wait 方法时才有用。

threading - 标记值或事件来打破循环

threading - sentinel value or Event to break loops

python

multithreading

thread-safety

python-multithreading

python-3.x