如何在共享資源時避免python線程中的全局？

Question

我想在python中建立一個依賴於多個線程的程序，在線程之間共享數據。我試圖避免使用全局關鍵字來做這件事，但目前爲止沒有取得任何進展。

作爲一個簡單的例子（下面的代碼），我的main（）函數生成一個線程thread1，它應該能夠訪問變量count，在這種情況下只是爲了打印它。與此同時，main（）迭代這個變量，並且thread1應該能夠看到計數改變。一些自包含的代碼在這裏：

import threading 
import time 

class myThread (threading.Thread): 

    def __init__(self, threadID): 
     self.threadID = threadID 
     threading.Thread.__init__(self) 

    def run(self): 
     global count 
     for i in range(10): 
      print "count is now: ", count, " for thread ", self.threadID, "\n" 
      time.sleep(5) 


def main(): 

    global count 
    count = 0 

    # spawn one or more threads 
    thread1 = myThread(1) 
    thread1.start() 

    for i in range(20): 
     time.sleep(2) 
     count = count + 1 

    # wait for thread1 to finish 
    thread1.join() 

main() 

當閱讀有關蟒蛇線程，我還沒有發現任何其他方式來做到這一點比使用全球。然而，在閱讀全球時，大多數人認爲你應該很少使用它，因爲很好的理由，有些人甚至認爲它應該完全從Python中刪除。所以我想知道是否實際上有另一種方法讓thread1「被動地」檢測到main（）已經迭代計數並訪問該新值？例如。我不太瞭解python和指針（它們甚至存在於python中嗎？），但我會認爲這正是全球達到的目標。

理想情況下，我可以從main（）調用一個thread1方法來設置一個新的self.count，只要count被迭代，但是因爲thread1有一個阻塞的run（）方法，我看不到如何做這在thread1內部沒有另外一個獨立的線程，這看起來太複雜了。

Answer 1

您可以創建線程對象並填寫類屬性。

import threading 
class MyThreadClass(threading.Thread): 
    def __init__(self, fruits): 
    threading.Thread.__init__(self) 
    self.fruits = fruits  

    def run(self): 
    self.fruits.append('banana') 

list_fruit = ['apple', 'orange']  
print 'BEFORE:', list_fruit 
thread = MyThreadClass(list_fruit) 
thread.start() 
thread.join() #Wait for the thread to finish 
print 'AFTER:', list_fruit 

輸出：

BEFORE: ['apple', 'orange'] 
AFTER: ['apple', 'orange', 'banana'] 

對於你的情況，你可以嘗試：

import threading 
import time 

class myThread (threading.Thread): 

    def __init__(self, threadID): 
     self.threadID = threadID 
     self.count = 0 
     threading.Thread.__init__(self) 

    def run(self): 
     for i in range(10): 
      print "count is now: ", self.count, " for thread ", self.threadID, "\n" 
      time.sleep(5) 


def main():  
    # spawn one or more threads 
    thread1 = myThread(1) 
    thread1.start() 

    for i in range(20): 
     time.sleep(2) 
     thread1.count = thread1.count + 1 

    # wait for thread1 to finish 
    thread1.join() 
    print thread1.count 

main() 

如果你想使用多個線程之間共享相同的數，你可以把你的計數一個只包含一個元素的列表。 這樣，當爲線程屬性分配計數時，它不會是硬拷貝。