GObject.idle_add()、thread.join() 和我的程序挂起

Question

我有一个问题：我的主线程应该启动并加入一个运行大约 10-15 秒的线程。

所以：

• 我的主线程启动一个子线程，它必须运行大约 10-15 秒
• 我的主线程加入子线程：主线程需要子线程的结果
• 在子线程运行的同时，我要更新 GUI，它只是一个进度条（可能每 0.2 秒）
• 更新 GUI：我将使用 递归函数
• 子线程结束，主线程得到结果

我的代码的问题是 Trovarete_Window 仅在工作函数结束时才会出现并开始更新。所以我的程序挂起/冻结，直到工人运行。

这是我的代码：

def collega_GUI(widget, args=()):

    builder.get_object('Trovarete_Window').show_all()
    progressbar.set_pulse_step(0.20)

    pulse()
    t = threading.Thread(target=worker)
    t.setDaemon(True)
    t.start()
    t.join()
    print 'a'


def pulse():

    if not event.is_set():
        progressbar.pulse()
        GObject.timeout_add(300, pulse)


def worker():
    #hard work

Answer 1

问题是您在collegea_GUI 中调用t.join()。调用t.join() 意味着你的主线程——运行事件循环的线程——被阻塞直到worker 完成。只要你被collegea_GUI 阻塞，你的主循环就不能运行，这意味着你安排的对pulse 的调用不能运行，GUI 也不能更新。

您需要执行与使用pulse 类似的操作，而不是调用t.join() - 安排一个函数运行，该函数执行非阻塞检查以查看worker 是否已完成。像这样的：

def collega_GUI(widget, args=()):

    builder.get_object('Trovarete_Window').show_all()
    progressbar.set_pulse_step(0.20)

    pulse()
    t = threading.Thread(target=worker)
    t.setDaemon(True)
    t.start()
    wait_for_t(t)

def wait_for_t(t):
   if not t.is_alive():
       t.join() # This won't block, since the thread isn't alive anymore
       print 'a'
       # Do whatever else you would do when join() (or maybe collega_GUI?) returns
   else:
       Gobject.timeout_add(200, wait_for_t, t)