Python Threading：使线程函数从外部信号返回

Question

谁能指出这段代码有什么问题。我试图通过一个变量标志返回线程，我想在我的主线程中控制它。

test27.py

import threading
import time

lock = threading.Lock()

def Read(x,y):
    flag = 1
    while True:
        lock.acquire()
        try:
            z = x+y; w = x-y
            print z*w
            time.sleep(1)
            if flag == 0:
                print "ABORTING"
                return
        finally:
            print " SINGLE run of thread executed"
            lock.release()

test28.py

import time, threading

from test27 import Read

print "Hello Welcome"
a = 2; b = 5
t = threading.Thread(target = Read, name = 'Example Thread', args = (a,b))
t.start()
time.sleep(5)
t.flag = 0 # This is not updating the flag variable in Read FUNCTION
t.join() # Because of the above command I am unable to wait until the thread finishes. It is blocking.
print "PROGRAM ENDED"

Answer 1

不应在线程中跟踪常规变量。这样做是为了防止竞争条件。您必须使用线程安全构造在线程之间进行通信。对于一个简单的标志使用threading.Event。您也不能通过线程对象访问局部变量flag。它是本地的，并且仅在范围内可见。您必须使用全局变量，如下面的示例所示，或者在调用线程并使用成员变量之前创建一个对象。

from threading import Event
flag = Event()

def Read(x,y):
    global flag
    flag.clear()
    ...
    if flag.is_set():
        return

主线程：

sleep(5)
flag.set()

P.S.：我刚刚注意到您尝试在线程中使用 lock()，但未能在主线程中使用它。对于一个简单的标志去事件。对于 lock()，您需要锁定这两个部分并降低死锁的风险。

Answer 2

Thread 类可以使用target 参数进行实例化。然后你只需给它一个应该在新线程中执行的函数。这是一种启动简单线程的便捷方式，但为了获得更多控制权，通常更容易从Thread 继承一个类，该类具有额外的成员变量，例如用于中止的flag。

例如：

import time
import threading

class MyThread(threading.Thread):
    def __init__(self, x, y):
        super().__init__()
        # or in Python 2:
        # super(MyThread, self).__init__()
        self.x = x
        self.y = y
        self._stop_requested = False

    def run(self):
        while not self._stop_requested:
            z = self.x + self.y
            w = self.x - self.y
            print (z * w)
            time.sleep(1)

    def stop(self, timeout=None):
        self._stop_requested = True
        self.join(timeout)

然后，要启动线程，调用start()，然后停止它调用stop()：

>>> def run_thread_for_5_seconds():
...     t = MyThread(3, 4)
...     t.start()
...     time.sleep(5)
...     t.stop()
...
>>> run_thread_for_5_seconds()
-7
-7
-7
-7
-7
>>>