我想要兩個過程，一個寫入，一個讀取/從同一變量讀取。寫入的數據如下所示：[0, 0][0, 1][1, 0][1, 1][2, 0][2, 1][3, 0][3, 1][4, 0][4, 1][5, 0][5, 1][6, 0][6, 1][7, 0][7, 1][8, 0][8, 1][9, 0][9, 1]但是我遇到了麻煩，因為讀取過程是在變量變化之間讀取，形成新的對，所以我想使用Lock/Mutex來防止這種情況再次發生。我想我必須在更改對象之前鎖定它。OBS：使用管理器在進程之間共享對象。下面是主代碼：import multiprocessingdef mde(dad, mutex): for i in range(10): for j in range(2): mutex.acquire() dad[0] = i dad[1] = j mutex.release()def mda(dad): c = 0 while c < 30: print(dad) c += 1if __name__ == '__main__': manager = multiprocessing.Manager() mutex = manager.Lock() dado = manager.list([0, 0]) p1 = multiprocessing.Process(target=mde, args=(dado, mutex,)) p2 = multiprocessing.Process(target=mda, args=(dado,)) p1.start() p2.start() p1.join() p2.join()如您所見，我試圖在編寫過程中鎖定和解鎖變量，但結果仍然很混亂。我做錯了什么？
1 回答
慕標5832272
TA貢獻1966條經驗 獲得超4個贊
這是更正后的版本（歸功于宮城先生）。兩個工人都在等待對方完成他們的任務，即修改列表或顯示它。
import multiprocessing
NX = 10
NY = 2
def mde(dad, mutex):
for i in range(NX):
for j in range(NY):
mutex.acquire()
dad[0] = i
dad[1] = j
mutex.release()
def mda(dad, mutex):
c = 0
while c <= NX*NY:
mutex.acquire()
print(dad)
c += 1
mutex.release()
if __name__ == '__main__':
manager = multiprocessing.Manager()
mutex = manager.Lock()
dado = manager.list([0, 0])
p1 = multiprocessing.Process(target=mde, args=(dado, mutex,))
p2 = multiprocessing.Process(target=mda, args=(dado, mutex,))
p1.start()
p2.start()
p1.join()
p2.join()
添加回答
舉報
0/150
提交
取消