Skip to content

Commit

Permalink
added pool,lock,queue,pipe
Browse files Browse the repository at this point in the history
  • Loading branch information
learnp committed Oct 15, 2016
1 parent f1f6905 commit 71eece4
Show file tree
Hide file tree
Showing 4 changed files with 31 additions and 44 deletions.
4 changes: 0 additions & 4 deletions Multiprocessing/multiprocessing_lock.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,14 +18,10 @@ def withdraw(balance, lock):
if __name__ == '__main__':
balance = multiprocessing.Value('i', 200)
lock = multiprocessing.Lock()

d = multiprocessing.Process(target=deposit, args=(balance,lock))
w = multiprocessing.Process(target=withdraw, args=(balance,lock))

d.start()
w.start()

d.join()
w.join()

print(balance.value)
11 changes: 11 additions & 0 deletions Multiprocessing/multiprocessing_pool.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
from multiprocessing import Pool


def f(n):
return n*n

if __name__ == "__main__":
p = Pool(processes=3)
result = p.map(f,[1,2,3,4,5])
for n in result:
print(n)
20 changes: 20 additions & 0 deletions Multiprocessing/multiprocessing_queue_pipe.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
import multiprocessing

def calc_square(numbers, q):
for n in numbers:
q.put(n*n)

if __name__ == "__main__":
numbers = [2,3,5]
q = multiprocessing.Queue()
p = multiprocessing.Process(target=calc_square, args=(numbers,q))

p.start()
p.join()

while q.empty() is False:
print(q.get())




40 changes: 0 additions & 40 deletions lists

This file was deleted.

0 comments on commit 71eece4

Please sign in to comment.