Python 中 threading.Thread.join() 的使用方法

本文主要是介绍Python 中 threading.Thread.join() 的使用方法，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

threading.Thread.join() 方法用于阻塞当前线程，直到调用它的线程对象执行完成或者超时。这在需要等待子线程执行完毕后再继续执行主线程时非常有用。基于他这种特性，我讲用我的方法帮你选择你合适的解决方案。

问题背景

在 Python 中，想要充分利用多线程的优势，就需要对 threading 模块中的 Thread 类有一定的了解。这里有一个非常简单的多线程程序，用于帮助我们理解 threading.Thread.join 方法。

import threadingval = 0def increment():global valprint("Inside increment")for x in range(100):val += 1print("val is now {} ".format(val))thread1 = threading.Thread(target=increment, args=())
thread2 = threading.Thread(target=increment, args=())
thread1.start()
# thread1.join()
thread2.start()
# thread2.join()

这里有两个问题：

1. 如果注释掉 thread1.join() 和 thread2.join()，那么输出结果会是怎样的？
2. 如果不注释掉 thread1.join() 和 thread2.join()，那么输出结果又会是怎样的？

解决方法

1. 不注释掉 join() 方法

如果我们不注释掉 thread1.join() 和 thread2.join()，那么输出结果如下：

Inside increment
val is now 1
val is now 2
val is now 3
...
val is now 100
Inside increment
val is now 1
val is now 2
val is now 3
...
val is now 100

2. 注释掉 join() 方法

如果我们注释掉 thread1.join() 和 thread2.join()，那么输出结果如下：

Inside increment
Inside increment
val is now 1
val is now 1
val is now 2
val is now 3
...
val is now 99
val is now 2
val is now 3
...
val is now 98
val is now 99
val is now 100

比较输出结果

通过比较这两个输出结果，我们可以发现，如果注释掉 join() 方法，那么两个线程的输出结果是交织在一起的，这表明这两个线程是并发执行的。而如果不注释掉 join() 方法，那么两个线程的输出结果是按照顺序输出的，这表明这两个线程是串行执行的。

join() 方法的作用

join() 方法的作用是让调用它的线程等待另一个线程终止。在我们的例子中，thread1.join() 和 thread2.join() 的作用是让主线程等待 thread1 和 thread2 两个线程终止。如果不注释掉这两个方法，那么主线程就会等待这两个线程终止后才继续执行。而如果注释掉这两个方法，那么主线程就不会等待这两个线程终止，而是直接继续执行。

代码示例：

为了更清楚地了解 join() 方法的作用，我们修改一下上面的代码：

import threadingval = 0def increment(msg,sleep_time):global valprint("Inside increment")for x in range(10):val += 1print("%s : %d\n" % (msg,val))time.sleep(sleep_time)thread1 = threading.Thread(target=increment, args=("thread_01",0.5))
thread2 = threading.Thread(target=increment, args=("thread_02",1))
thread1.start()
thread1.join()
thread2.start()
thread2.join()

如果我们运行这段代码，那么输出结果如下：

Inside increment
thread_01 : 1thread_01 : 2thread_01 : 3thread_01 : 4thread_01 : 5thread_01 : 6thread_01 : 7thread_01 : 8thread_01 : 9thread_01 : 10Inside increment
thread_02 : 1thread_02 : 2thread_02 : 3thread_02 : 4thread_02 : 5thread_02 : 6thread_02 : 7thread_02 : 8thread_02 : 9thread_02 : 10

从输出结果中，我们可以看到，这两个线程是按照顺序输出的，这表明这两个线程是串行执行的。这是因为我们在代码中使用了 thread1.join() 和 thread2.join() 这两个方法，让主线程等待这两个线程终止后才继续执行。

在这个例子中，主线程启动了一个子线程，并在子线程执行完成之前调用了 join() 方法来等待子线程执行完成。如有任何疑问可以评论区留言讨论。

这篇关于Python 中 threading.Thread.join() 的使用方法的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---