快捷導(dǎo)航

Python THREADING模塊中的JOIN()方法深入理解

更新時間：2015年02月18日 16:50:32 投稿：junjie

這篇文章主要介紹了Python THREADING模塊中的JOIN()方法深入理解,本文用簡潔易懂的語言總結(jié)了對JOIN()方法的理解,不同于其它文章,需要的朋友可以參考下

看了oschina上的兩個代碼，受益匪淺。其中對join()方法不理解，看python官網(wǎng)文檔的介紹：
join([timeout])：等待直到進程結(jié)束。這將阻塞正在調(diào)用的線程，直到被調(diào)用join()方法的線程結(jié)束。（好難翻譯，應(yīng)該是這個意思）

哈哈，這個易懂。
join方法，如果一個線程或者一個函數(shù)在執(zhí)行過程中要調(diào)用另外一個線程，并且待到其完成以后才能接著執(zhí)行，那么在調(diào)用這個線程時可以使用被調(diào)用線程的join方法。

復(fù)制代碼代碼如下:

#-*- encoding: gb2312 -*-

import string, threading, time

def thread_main(a):

    global count, mutex

    # 獲得線程名

    threadname = threading.currentThread().getName()

    for x in xrange(0, int(a)):

        # 取得鎖

        mutex.acquire()

        count = count + 1

        # 釋放鎖

        mutex.release()

        print threadname, x, count

        time.sleep(1)

def main(num):

    global count, mutex

    threads = []

    count = 1

    # 創(chuàng)建一個鎖

    mutex = threading.Lock()

    # 先創(chuàng)建線程對象

    for x in xrange(0, num):

        threads.append(threading.Thread(target=thread_main, args=(10,)))

    # 啟動所有線程

    for t in threads:

        t.start()

    # 主線程中等待所有子線程退出

    for t in threads:

        t.join()  

if __name__ == '__main__':

    num = 4

    # 創(chuàng)建4個線程

    main(4)

###################################################################

#-*- encoding: gb2312 -*-

import threading

import time

class Test(threading.Thread):

    def __init__(self, num):

        threading.Thread.__init__(self)

        self._run_num = num

    def run(self):

        global count, mutex

        threadname = threading.currentThread().getName()

        for x in xrange(0, int(self._run_num)):

            mutex.acquire()

            count = count + 1

            mutex.release()

            print threadname, x, count

            time.sleep(1)

if __name__ == '__main__':

    global count, mutex

    threads = []

    num = 4

    count = 1

    # 創(chuàng)建鎖

    mutex = threading.Lock()

    # 創(chuàng)建線程對象

    for x in xrange(0, num):

        threads.append(Test(10))

    # 啟動線程

    for t in threads:

        t.start()

    # 等待子線程結(jié)束

    for t in threads:

        t.join()

在程序中，最后join()方法的調(diào)用就明白了，是主進程挨個調(diào)用子線程的join()方法。當(dāng)四個線程都執(zhí)行完畢后，主線程才會執(zhí)行下面的代碼，在這里也就是退出了。
相對應(yīng)的在網(wǎng)上一起找到的另一個方法：
3.守護進程

setDaemon()

這個方法基本和join是相反的。當(dāng)我們在程序運行中，執(zhí)行一個主線程，如果主線程又創(chuàng)建一個子線程，主線程和子線程就分兵兩路，分別運行，那么當(dāng)主線程完成想退出時，會檢驗子線程是否完成。如果子線程未完成，則主線程會等待子線程完成后再退出。但是有時候我們需要的是，只要主線程完成了，不管子線程是否完成，都要和主線程一起退出，這時就可以用setDaemon方法啦

您可能感興趣的文章: