python中_thread模塊是一個低級別的多線程模塊,它的問題在于主線程運行完畢后,會立馬把子線程給結束掉,不加處理地使用_thread模塊是不合適的.這里把書中講述的有關_thread使用的例子自己實現了一遍,做以記錄.

#例子一:自己手動在主線程中設置等待時間
import _thread from time import ctime, sleepdef loop0():print("loop0 starts at:{}".format(ctime()))sleep(4)print("loop0 ends at:{}".format(ctime()))def loop1():print("loop1 starts at:{}".format(ctime()))sleep(2)print("loop1 ends at:{}".format(ctime()))if __name__ == "__main__":print("start_time:{}".format(ctime()))_thread.start_new_thread(loop0, ())_thread.start_new_thread(loop1, ())#此處設置sleep(6)是因為_thread主線程結束后,會馬上殺死其他線程sleep(6)print("end_time:{}".format(ctime())) #例子二:通過鎖可以實現所有線程全部運行后立即退出
import _thread from time import ctime, sleep#每個loop等待的時間 wait_time_list = [4, 2]def loop(i, wait_time, lock):"""根據傳入參數創建多個loop函數:param i::param wait_time::param lock::return:"""print("loop{} starts at:{}".format(i, ctime()))sleep(wait_time)print("loop{} ends at:{}".format(i, ctime()))#釋放鎖 lock.release()def main():print("start_time:", ctime())nloops = range(len(wait_time_list))locks = []
#創建鎖,上鎖for i in nloops:lock = _thread.allocate_lock()lock.acquire()locks.append(lock)#之所以另起一個循環,是為了盡量保證所有線程能夠同時啟動,因為上面的循環中鎖的操作也要花費一些時間for i in nloops:_thread.start_new_thread(loop, (i, wait_time_list[i], locks[i]))#loop函數中的參數放到元組里#等待所有的子線程釋放鎖后,結束主線程.(等待時間取決于執行時間最長的子線程,假如第一個子線程執行時間最長,等它執行完畢,下面的循環就不會再進入了.)for i in nloops:#注意這里locked()要帶括號while locks[i].locked():passprint("all done! end_time:", ctime())if __name__ == '__main__':main()

?

轉載于:https://www.cnblogs.com/Stephen-Qin/p/10354071.html

總結

以上是生活随笔為你收集整理的python的_thread模块来实现多线程(python核心编程例子)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。