Python threading Thread多線程的使用方法

參考資料：《Python 多線程》http://www.runoob.com/python/python-multithreading.html

目錄

Python threading Thread多線程的使用方法

1.使用Threading模塊創(chuàng)建線程

2.Thread線程同步

3.使用多線程讀取圖像并返回?cái)?shù)據(jù)

---

1.使用Threading模塊創(chuàng)建線程

使用Threading模塊創(chuàng)建線程，直接從threading.Thread繼承，然后重寫__init__方法和run方法：

#!/usr/bin/python # -*- coding: UTF-8 -*-import threading import timeexitFlag = 0class myThread (threading.Thread): #繼承父類threading.Threaddef __init__(self, threadID, name, counter):threading.Thread.__init__(self)self.threadID = threadIDself.name = nameself.counter = counterdef run(self): #把要執(zhí)行的代碼寫到run函數(shù)里面 線程在創(chuàng)建后會(huì)直接運(yùn)行run函數(shù) print "Starting " + self.nameprint_time(self.name, self.counter, 5)print "Exiting " + self.namedef print_time(threadName, delay, counter):while counter:if exitFlag:(threading.Thread).exit()time.sleep(delay)print "%s: %s" % (threadName, time.ctime(time.time()))counter -= 1# 創(chuàng)建新線程 thread1 = myThread(1, "Thread-1", 1) thread2 = myThread(2, "Thread-2", 2)# 開啟線程 thread1.start() thread2.start()print "Exiting Main Thread"

以上程序執(zhí)行結(jié)果如下；

Starting Thread-1 Starting Thread-2 Exiting Main Thread Thread-1: Thu Mar 21 09:10:03 2013 Thread-1: Thu Mar 21 09:10:04 2013 Thread-2: Thu Mar 21 09:10:04 2013 Thread-1: Thu Mar 21 09:10:05 2013 Thread-1: Thu Mar 21 09:10:06 2013 Thread-2: Thu Mar 21 09:10:06 2013 Thread-1: Thu Mar 21 09:10:07 2013 Exiting Thread-1 Thread-2: Thu Mar 21 09:10:08 2013 Thread-2: Thu Mar 21 09:10:10 2013 Thread-2: Thu Mar 21 09:10:12 2013 Exiting Thread-2

2.Thread線程同步

如果多個(gè)線程共同對(duì)某個(gè)數(shù)據(jù)修改，則可能出現(xiàn)不可預(yù)料的結(jié)果，為了保證數(shù)據(jù)的正確性，需要對(duì)多個(gè)線程進(jìn)行同步。使用Thread對(duì)象的Lock和Rlock可以實(shí)現(xiàn)簡(jiǎn)單的線程同步，這兩個(gè)對(duì)象都有acquire方法和release方法，對(duì)于那些需要每次只允許一個(gè)線程操作的數(shù)據(jù)，可以將其操作放到acquire和release方法之間。

多線程的優(yōu)勢(shì)在于可以同時(shí)運(yùn)行多個(gè)任務(wù)（至少感覺起來是這樣）。但是當(dāng)線程需要共享數(shù)據(jù)時(shí)，可能存在數(shù)據(jù)不同步的問題。

考慮這樣一種情況：一個(gè)列表里所有元素都是0，線程"set"從后向前把所有元素改成1，而線程"print"負(fù)責(zé)從前往后讀取列表并打印。

那么，可能線程"set"開始改的時(shí)候，線程"print"便來打印列表了，輸出就成了一半0一半1，這就是數(shù)據(jù)的不同步。為了避免這種情況，引入了鎖的概念。

鎖有兩種狀態(tài)——鎖定和未鎖定。每當(dāng)一個(gè)線程比如"set"要訪問共享數(shù)據(jù)時(shí)，必須先獲得鎖定；如果已經(jīng)有別的線程比如"print"獲得鎖定了，那么就讓線程"set"暫停，也就是同步阻塞；等到線程"print"訪問完畢，釋放鎖以后，再讓線程"set"繼續(xù)。

經(jīng)過這樣的處理，打印列表時(shí)要么全部輸出0，要么全部輸出1，不會(huì)再出現(xiàn)一半0一半1的尷尬場(chǎng)面。

# -*-coding: utf-8 -*- """@Project: cluster@File : thread_processing.py@Author : panjq@E-mail : pan_jinquan@163.com@Date : 2019-03-13 13:43:49 """ # !/usr/bin/python # -*- coding: UTF-8 -*-# !/usr/bin/python # -*- coding: UTF-8 -*-import threading import timeclass myThread(threading.Thread):def __init__(self, threadID, name, counter):threading.Thread.__init__(self)self.threadID = threadIDself.name = nameself.counter = counterdef run(self):print("Starting " + self.name)# 獲得鎖，成功獲得鎖定后返回True# 可選的timeout參數(shù)不填時(shí)將一直阻塞直到獲得鎖定# 否則超時(shí)后將返回FalsethreadLock.acquire()self.print_time(self.name, self.counter, 3)# 釋放鎖threadLock.release()def print_time(self,threadName, delay, counter):while counter:time.sleep(delay)print("%s: %s" % (threadName, time.ctime(time.time())))counter -= 1threadLock = threading.Lock() threads = []# 創(chuàng)建新線程 thread1 = myThread(1, "Thread-1", 1) thread2 = myThread(2, "Thread-2", 2)# 開啟新線程 thread1.start() thread2.start()# 添加線程到線程列表 threads.append(thread1) threads.append(thread2)# 等待所有線程完成 for t in threads:t.join() print("Exiting Main Thread")

3.使用多線程讀取圖像并返回?cái)?shù)據(jù)

下面是使用多線程的方法，實(shí)現(xiàn)讀取圖片的方法，注意這里增加了一個(gè)函數(shù)get_result，用于返回每個(gè)線程處理后的數(shù)據(jù)

其中file_processing和image_processing是本人包裝好的文件處理方法和圖像處理方法，具體實(shí)現(xiàn)的代碼，這里不貼出來了，源碼可查看：

file_processing：《Python常用的模塊的使用技巧》https://panjinquan.blog.csdn.net/article/details/80805807#file_processing.py

image_processing：《Python常用的模塊的使用技巧》https://panjinquan.blog.csdn.net/article/details/80805807#image_processing.py

# -*-coding: utf-8 -*- """@Project: cluster@File : thread_operate.py@Author : panjq@E-mail : pan_jinquan@163.com@Date : 2019-03-13 13:43:49 """from utils import file_processing,image_processing import threading import timethreadLock = threading.Lock()#創(chuàng)建線程鎖class FeatureThread(threading.Thread):def __init__(self, thread_id, func, args=()):''':param thread_id::param func::param args:'''threading.Thread.__init__(self)self.thread_id = thread_idself.func = funcself.args = argsdef run(self):print("Starting thread_id:{} ".format(self.thread_id))# 獲得鎖，成功獲得鎖定后返回True， 可選的timeout參數(shù)不填時(shí)將一直阻塞直到獲得鎖定， 否則超時(shí)后將返回False# threadLock.acquire() #線程加鎖self.result = self.func(*self.args)# threadLock.release()# 釋放鎖def get_result(self):try:return self.resultexcept Exception:return Nonedef test_fun(images_list):time.sleep(2)print(images_list)images=[]for filename in images_list:image = image_processing.read_image(filename, resize_height=224, resize_width=224, normalization=False)images.append(image)return imagesdef split_data_list(data_list, split_nums):''':param data_list: 數(shù)據(jù)列表:param split_nums: 將列表分成多少塊，注意split_nums塊必須小于data_list的長(zhǎng)度:return: 返回data_list分塊后的索引'''data_size=len(data_list)if split_nums>data_size:print("illegal arguments,split_nums must be less than len(data_size)")exit(0)batch_index=[]for i in range(split_nums):start = int(data_size / split_nums * i)end = int(data_size / split_nums * (i + 1))if (i == split_nums - 1) :end = data_sizebatch_index.append((start,end))return batch_indexdef thread_test(images_list, nums_thread=4):thread_collection = []#創(chuàng)建線程容器# 創(chuàng)建新線程batch_index=split_data_list(images_list, split_nums=nums_thread)print("batch_index:{}".format(batch_index))for i in range(nums_thread):start,end=batch_index[i]batch_image_list=images_list[start:end]thread = FeatureThread(thread_id=i, func=test_fun, args=(batch_image_list,))thread.start() # 開啟新線程thread_collection.append(thread)# 添加線程到線程列表# 等待所有線程完成for thread in thread_collection:thread.join()batch_image=thread.get_result()image_processing.show_image(title="image",image=batch_image[0])print("Exiting Main Thread")if __name__=='__main__':image_dir="../dataset/test_images"images_list = file_processing.get_images_list(image_dir, postfix=['*.png', '*.JPG'])print(images_list)thread_test(images_list, nums_thread=4)

?

總結(jié)

以上是生活随笔為你收集整理的Python threading Thread多线程的使用方法的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。