我正在尝试创建一个简单的程序,使用套接字等待文件,然后将输出返回到另一个线程的文本字段。
我做了一些研究,我知道线程的基本原理,但是我不明白多个线程是如何相互连接的。
我的问题是WindowManager.addText
函数只在WindowManager
类本身的事件上更新,而不是从ConnectionManager
类更新。我怎么能解决这个问题,所以每次WindowManager.addText
在另一个线程上被调用,它立即得到更新?
我得到了一个WindowManager
类,它将字符串保存到文本字段(用GTK加载):
class WindowManager:
def __init__(self):
#Load the window here, not relevant
self.textBuffer = self.messagePanel.get_buffer()
self.lock = threading.Lock()
def addText(self, text, *args):
self.lock.acquire()
logging.debug('Waiting for lock')
try:
logging.debug('Acquired lock')
self.textBuffer.insert_with_tags_by_name(self.textBuffer.get_end_iter(), text, *args)
finally:
self.lock.release()
现在我在这里也得到了一个ConnectionManager
类,它加载连接线程:
class ConnectionManager:
def __init__(self, windowManager):
self.ping = PingThread(windowManager)
self.ping.setDaemon(True)
self.ping.start()
最后我有PingThread
类,它是实际的连接线程,在这个例子中,我随机调用线程:
class PingThread(threading.Thread):
def __init__(self, window, group=None, target=None, name=None, verbose=None):
threading.Thread.__init__(self, group=group, target=target, name=name, verbose=verbose)
self.window = window
def run(self):
while True:
self.window.addText("Test")
time.sleep(random.randrange(1,10))
在Stack Overflow上搜索了一些之后,我找到了答案。我所需要做的就是初始化线程,把下面的代码放在代码的开头:GObject.threads_init()