【问题标题】:Time.sleep seems to be blocking main thread, not just child thread?Time.sleep 似乎阻塞了主线程,而不仅仅是子线程?
【发布时间】:2018-03-03 04:51:27
【问题描述】:

我正在运行以下代码:

from threading import Thread
from time import sleep

def file_write(file_input, num_lines):
    sleep(10)
    file = open("testfile.txt", "w")
    for line in num_lines:
        file.write("{}: {}".format(line, file_input))

    file.close()


if __name__ == '__main__':
    curr_thread = Thread(target=file_write, args=("Norah", range(5)))
    curr_thread.daemon = False
    curr_thread.start()

期望是主线程会立即退出,因为我没有调用join。但事实并非如此。睡眠调用也会阻塞主线程吗?

编辑:在这个线程中有一个类似的问题:time.sleep -- sleeps thread or process? 但它不一样。
我查看了线程:它说睡眠不会导致子进程相互阻塞,但它没有说明主线程会发生什么。当我从接受的答案运行代码时,主线程并没有像我想的那样立即退出。

更新:看起来多线程无法解决我的问题:目的是在后台运行一堆任务。我现在正在使用 subprocess 模块。

【问题讨论】:

  • 我查看了线程:它说睡眠不会导致子进程相互阻塞,但它没有说明主线程会发生什么。当我从接受的答案运行代码时,主线程并没有像我想的那样立即退出。
  • 你在做curr_thread.join()吗?主线程应立即退出。加入线程会等到线程完成后再退出。
  • 我没有进行任何加入调用:我只运行我上面粘贴的内容。
  • 我刚刚运行了代码here。自己试试吧。你应该看到它打印出“a”、“b”、“d”、“e”、(主线程退出)、“c”。编辑:我也运行了您的代码,主线程按您的预期立即退出。

标签: python multithreading sleep


【解决方案1】:

睡眠调用只会阻塞调用它们的线程。在调用 curr_thread.start() 后立即在主线程中打印任何内容将向您证明这一点。

但是,如果您中断代码 (Ctrl-C),您将看到有用的堆栈跟踪。最后一次调用在 threading 模块的 _shutdown() 方法内,它似乎正在等待所有 非守护进程线程完成。

t = _pickSomeNonDaemonThread()
while t:
    t.join()
    t = _pickSomeNonDaemonThread()

阅读 the documentation 的线程模块,你可以看到:“当没有存活的非守护线程时,整个 Python 程序退出。”所以,因为你已经完成了curr_thread.daemon = False,所以你强制主线程等待这个线程首先完成。

不过,我应该指出,线程继承了它们父母的“守护进程”。由于主线程从来都不是守护线程,因此您可以不使用curr_thread.daemon = False,并且会得到相同的行为。

【讨论】:

  • 问题是,如果我设置 curr_thread.daemon = True,那么程序会立即退出,但子线程似乎在进程中被拆除:文件写入调用不执行。跨度>
  • @NorahBorus 是的,第二个线程将被终止。这是因为整个进程都退出了,因为已经没有非守护线程了。如果设置curr_thread.daemon = True,主线程是唯一的非守护线程,对吧?所以当它完成时(立即,因为你从来没有join()),整个过程将退出。
  • @NorahBorus 这开始看起来有点像 XY 问题。为什么要创建第二个线程?或者这是一个理解线程模块的练习?
  • 我试图使用线程模块在后台运行一些任务,但似乎不是这样。我将改用 subprocess 模块。感谢您的澄清。
【解决方案2】:

当然,线程中的睡眠不会阻塞主线程。

这段代码演示了 main 继续:

from threading import Thread
from time import sleep

def file_write(file_input, num_lines):
    print('a')
    sleep(5)
    print('b')


if __name__ == '__main__':
    curr_thread = Thread(target=file_write, args=("Norah", range(5)))
    curr_thread.daemon = False
    curr_thread.start()
    for i in range(5):
        sleep(1)
        print(i)

输出:

a
0
1
2
3
b
4

【讨论】:

  • 查看 bnaeckner 的评论和我的代码示例:我指定问题是关于主线程退出时会发生什么。
猜你喜欢
  • 2013-05-14
  • 2017-12-24
  • 2023-03-11
  • 1970-01-01
  • 2012-12-18
  • 1970-01-01
  • 2018-02-16
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多