Skip to content

Commit ff2121f

Browse files
committed
Use lists instead of tuples for args
1 parent 6bdcaa0 commit ff2121f

File tree

12 files changed

+13
-13
lines changed

12 files changed

+13
-13
lines changed

Diff for: demos/lock.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -10,5 +10,5 @@ def hello(lock, id):
1010

1111
lock = Lock()
1212
for i in range(10):
13-
Process(target=hello, args=(lock, i)).start()
13+
Process(target=hello, args=[lock, i]).start()
1414

Diff for: demos/manager.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ def f(x):
77
manager = Manager()
88
fruits = manager.dict()
99

10-
p = Process(target=f, args=(fruits, ))
10+
p = Process(target=f, args=[fruits])
1111
p.start()
1212
p.join()
1313

Diff for: demos/pool.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -7,11 +7,11 @@ def f(x):
77
pool = Pool(8)
88

99
# Blocking execution (with a single process)
10-
result = pool.apply(f, (4,))
10+
result = pool.apply(f, [4])
1111
print(result)
1212

1313
# Non-blocking execution "in the background"
14-
result = pool.apply_async(f, (12,))
14+
result = pool.apply_async(f, [12])
1515
while not result.ready():
1616
print("waiting...")
1717
time.sleep(1)

Diff for: demos/shared-mem.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ def squared(a):
55
a[i] = a[i] * a[i]
66

77
numbers = Array('i', range(10))
8-
p = Process(target=squared, args=(numbers, ))
8+
p = Process(target=squared, args=[numbers])
99
p.start()
1010
p.join()
1111

Diff for: demos/spawn.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ def hello(name):
77
print("My parent's PID is {0}".format(os.getppid()))
88

99
# Create a new process
10-
p = Process(target=hello, args=('Alice', ))
10+
p = Process(target=hello, args=['Alice'])
1111

1212
# Start the process
1313
p.start()

Diff for: demos/task-queue.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ def f(q, i):
1616
n = 3 # no. of processes
1717
p = [] # list of processes
1818
for i in range(n):
19-
p.append(Process(target=f, args=(q, i, )))
19+
p.append(Process(target=f, args=[q, i]))
2020
q.put(None) # add sentinels to signal STOP
2121

2222
# start work on all processes

Diff for: multiprocessing/data-sharing/solution/data-manager.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ def squared(a, i):
77
numbers = manager.list()
88
numbers.extend(range(10))
99

10-
p = [Process(target=squared, args=(numbers, i, )) for i in range(10)]
10+
p = [Process(target=squared, args=[numbers, i]) for i in range(10)]
1111

1212
for i in range(10):
1313
p[i].start()

Diff for: multiprocessing/data-sharing/solution/shared-memory.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ def squared(a, i):
66
a.release()
77

88
numbers = Array('i', range(10))
9-
p = [Process(target=squared, args=(numbers, i, )) for i in range(10)]
9+
p = [Process(target=squared, args=[numbers, i]) for i in range(10)]
1010

1111
for i in range(10):
1212
p[i].start()

Diff for: multiprocessing/pipes/count-w.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ def count(pipe, letter):
99

1010
left, right = Pipe()
1111

12-
p = Process(target=count, args=(right, 'W'))
12+
p = Process(target=count, args=[right, 'W'])
1313
p.start()
1414

1515
fasta = Fasta('5ire.fasta.txt')

Diff for: multiprocessing/simple-calculation/solution/square.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ def squared(x):
44
print(x**2)
55

66
# create parallel processes
7-
procs = [Process(target=squared, args=(x,)) for x in range(10)]
7+
procs = [Process(target=squared, args=[x]) for x in range(10)]
88

99
# start all processes
1010
for p in procs:

Diff for: multiprocessing/work-distribution/solution/pool-of-workers.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ def average(chunk):
2323
# submit each task to the pool
2424
results = []
2525
for chunk in tasks:
26-
res = pool.apply_async(average, (chunk,))
26+
res = pool.apply_async(average, [chunk])
2727
results.append(res)
2828

2929
# wait for all tasks to finish

Diff for: multiprocessing/work-distribution/solution/queue.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ def worker(q, r):
3939
# create parallel processes
4040
p = []
4141
for i in range(size):
42-
p.append(Process(target=worker, args=(q, r)))
42+
p.append(Process(target=worker, args=[q, r]))
4343
q.put(None) # add sentinels to signal STOP
4444
p[i].start()
4545

0 commit comments

Comments
 (0)