如何停止wxpython中的线程？

Question

[问题] 我想停止调用函数的线程。

[CODE]

import wx 
app = wx.App(redirect=False) 
top = wx.Frame(None) 
sizer = wx.GridBagSizer() 
import threading 
shutdown_event = threading.Event() 
def testFunction(event): 
    while not shutdown_event.is_set(): 
     import time 
     for i in range(2): 
      print ('win','r') 
      time.sleep (0.5) 
      print ('abc') 
      time.sleep (0.5) 
      print ('enter') 
      time.sleep (0.5) 
      print 'sleep' 
      time.sleep (3) 


def startThread(event): 
    import threading 
    th = threading.Thread(target=testFunction, args=(event,)) 
    th.start() 


def stopThread(event): 
    shutdown_event.set() 



addButton = wx.Button(top, -1, "Start", style=wx.BU_EXACTFIT) 
sizer.Add(addButton, (6, 8), (2, 14), wx.EXPAND) 
stopButton = wx.Button(top, -1, "Stop", style=wx.BU_EXACTFIT) 
sizer.Add(stopButton, (8, 9), (2, 14), wx.EXPAND) 
top.Bind(wx.EVT_BUTTON, startThread, addButton) 
top.Bind(wx.EVT_BUTTON, stopThread, stopButton) 
top.Sizer = sizer 
top.Sizer.Fit(top) 
top.Show() 
app.MainLoop() 

[CURRENT]如果我点击 “停止” 按钮 什么也没有发生。

[DESIRED] 如果点击“停止”按钮，函数“testFunction”应该停止。

Answer 1

是的，它正在停止，事情是它没有被打断，它正在运行，直到脚本的两次迭代都完成，然后while condition被选中，然后停止。

import wx 
app = wx.App(redirect=False) 
top = wx.Frame(None) 
sizer = wx.GridBagSizer() 
import threading 
shutdown_event = threading.Event() 
def testFunction(event): 
    while not shutdown_event.is_set(): 
     import time 
     for i in range(2): 
      print u"Iteración {}".format(i) 
      if shutdown_event.is_set(): 
       break; 
      print ('win','r') 
      time.sleep (0.1) 
      if shutdown_event.is_set(): 
       break; 
      print ('abc') 
      time.sleep (0.1) 
      if shutdown_event.is_set(): 
       break; 
      print ('enter') 
      time.sleep (0.1) 
      if shutdown_event.is_set(): 
       break; 
      print 'sleep' 
      time.sleep (0.5) 
     print u"Fin de ejecución\n\n" 
    print u"Se detuvo la ejecución.\n\n" 


def startThread(event): 
    import threading 
    th = threading.Thread(target=testFunction, args=(event,)) 
    th.start() 


def stopThread(event): 
    shutdown_event.set() 


addButton = wx.Button(top, -1, "Start", style=wx.BU_EXACTFIT) 
sizer.Add(addButton, (6, 8), (2, 14), wx.EXPAND) 
stopButton = wx.Button(top, -1, "Stop", style=wx.BU_EXACTFIT) 
sizer.Add(stopButton, (8, 9), (2, 14), wx.EXPAND) 
top.Bind(wx.EVT_BUTTON, startThread, addButton) 
top.Bind(wx.EVT_BUTTON, stopThread, stopButton) 
top.Sizer = sizer 
top.Sizer.Fit(top) 
top.Show() 
app.MainLoop() 

Answer 2

如果你想在你的线程中有一个更精细的粒度，你必须实现它。使用类似的东西，用yield声明拆分生成器语句中的不同步骤：

def testFunction(event): 
    def inner_gen(): 
     print ('win','r') 
     time.sleep (0.5) 
     yield 
     print ('abc') 
     time.sleep (0.5) 
     yield 
     print ('enter') 
     time.sleep (0.5) 
     yield 
     print 'sleep' 
     time.sleep (3) 
     yield 

    while True: 
     for _ in range(2): 
      for _ in inner_gen(): 
       if shutdown_event.is_set(): 
        shutdown_event.clear() 
        return