1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
| import multiprocessing.shared_memory
|
|
| def producer(shr):
| with shr.txn() as shm:
| for i in range(10):
| shm[i] = i
|
|
| def consumer(shr):
| with shr.txn() as shm:
| for i in range(10):
| print(shm[i])
|
|
| if __name__ == "__main__":
| with multiprocessing.shared_memory.SharedMemory(create=True, size=80) as shr:
| p1 = multiprocessing.Process(target=producer, args=(shr,))
| p2 = multiprocessing.Process(target=consumer, args=(shr,))
| p1.start()
| p2.start()
| p1.join()
| p2.join()
|
|
