MyTetra Share
Делитесь знаниями!
Управление потоками wxPython
Время создания: 31.08.2017 21:00
Текстовые метки: code
Раздел: Python - Modules - wxPython - threadings
Запись: xintrea/mytetra_db_mcold/master/base/1501686605c72sxwi8jn/text.html на raw.githubusercontent.com
#coding: utf-8
"""
XRC is an XML-based resource format for wxPython. With it you can
define the layout of widgets, and then load that XRC at runtime to
create the layout. There are several GUI designers available that
understand the XRC format, a simple one called XRCed comes with
wxPython.
"""

import wx
import threading
import random


class WorkerThread(threading.Thread):
"""
This just simulates some long-running task that periodically sends
a message to the GUI thread.
"""
### TODO: в качестве окна принимаешь self = MyFrame
def __init__(self, threadNum, window):
threading.Thread.
__init__(self)
self.threadNum = threadNum
self.window = window
self.timeToQuit = threading.Event()
self.timeToQuit.clear()
self.messageCount = random.randint(10, 20)
self.messageDelay = 0.1 + 2.0 * random.random()

def stop(self):
self.timeToQuit.set()

def run(self):
msg =
"Thread %d iterating %d times with a delay of %1.4f\n" \
% (
self.threadNum, self.messageCount, self.messageDelay)
wx.CallAfter(
self.window.LogMessage, msg)

for i in range(1, self.messageCount + 1):
self.timeToQuit.wait(self.messageDelay)
if self.timeToQuit.isSet():
break
msg = "Message %d from thread %d\n" % (i, self.threadNum)
### TODO: Добавляем в текстовое поле сообщение
wx.CallAfter(self.window.LogMessage, msg)
else:
wx.CallAfter(
self.window.ThreadFinished, self)


class MyFrame(wx.Frame):
def __init__(self):
wx.Frame.
__init__(self, None, title="Multi-threaded GUI")
self.threads = []
self.count = 0

panel = wx.Panel(self)
startBtn = wx.Button(panel
, -1, "Start a thread")
stopBtn = wx.Button(panel
, -1, "Stop all threads")
self.tc = wx.StaticText(panel, -1, "Worker Threads: 00")
self.log = wx.TextCtrl(panel, -1, "",
style=wx.TE_RICH | wx.TE_MULTILINE)

inner = wx.BoxSizer(wx.HORIZONTAL)
inner.Add(startBtn
, 0, wx.RIGHT, 15)
inner.Add(stopBtn
, 0, wx.RIGHT, 15)
inner.Add(
self.tc, 0, wx.ALIGN_CENTER_VERTICAL)
main = wx.BoxSizer(wx.VERTICAL)
main.Add(inner
, 0, wx.ALL, 5)
main.Add(
self.log, 1, wx.EXPAND | wx.ALL, 5)
panel.SetSizer(main)

self.Bind(wx.EVT_BUTTON, self.OnStartButton, startBtn)
self.Bind(wx.EVT_BUTTON, self.OnStopButton, stopBtn)
self.Bind(wx.EVT_CLOSE, self.OnCloseWindow)

self.UpdateCount()

def OnStartButton(self, evt):
self.count += 1
### TODO: в качестве self передавать себя, т.е. окно
thread = WorkerThread(self.count, self)
self.threads.append(thread)
self.UpdateCount()
thread.start()

def OnStopButton(self, evt):
self.StopThreads()
self.UpdateCount()

def OnCloseWindow(self, evt):
self.StopThreads()
self.Destroy()

def StopThreads(self):
while self.threads:
thread =
self.threads[0]
thread.stop()
self.threads.remove(thread)

def UpdateCount(self):
self.tc.SetLabel("Worker Threads: %d" % len(self.threads))

def LogMessage(self, msg):
self.log.AppendText(msg)

def ThreadFinished(self, thread):
self.threads.remove(thread)
self.UpdateCount()


app = wx.App()
frm = MyFrame()
frm.Show()
app.MainLoop()
 
MyTetra Share v.0.65
Яндекс индекс цитирования