1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
from __future__ import print_function
import sys
import time
import threading
import Pyro4.naming
import Pyro4.core
if sys.version_info < (3, 0):
current_thread = threading.currentThread
else:
current_thread = threading.current_thread
stop = False
def myThread(nsproxy, proxy):
global stop
name = current_thread().getName()
try:
while not stop:
result = nsproxy.list(prefix="example.")
result = proxy.method("the quick brown fox jumps over the lazy dog")
except Exception as x:
print("**** Exception in thread %s: {%s} %s" % (name, type(x), x))
nsproxy = Pyro4.naming.locateNS()
proxy = Pyro4.core.Proxy("PYRONAME:example.proxysharing")
# now create a handful of threads and give each of them the same two proxy objects
threads = []
for i in range(5):
thread = threading.Thread(target=myThread, args=(nsproxy, proxy))
# thread.setDaemon(True)
thread.setDaemon(False)
threads.append(thread)
thread.start()
print("Running a bunch of threads for 5 seconds.")
print("They're hammering the name server and the test server using the same proxy.")
print("You should not see any exceptions.")
time.sleep(5)
stop = True
for thread in threads:
thread.join()
print("Done.")
print("\nNow showing why proxy sharing might not be a good idea for parallelism.")
print("Starting 10 threads with the same proxy that all call the work() method.")
def myThread2(proxy):
global stop
while not stop:
proxy.work()
stop = False
proxy.reset_work()
threads = []
for i in range(10):
thread = threading.Thread(target=myThread2, args=[proxy])
thread.setDaemon(False)
threads.append(thread)
thread.start()
print("waiting 5 seconds")
start = time.time()
time.sleep(5)
print("waiting until threads have stopped...")
stop = True
for thread in threads:
thread.join()
duration = int(time.time() - start)
print("--> time until everything completed: %.2f" % duration)
print("--> work done on the server: %d" % proxy.get_work_done())
print("you can see that the 10 threads are waiting for each other to complete,")
print("and that not a lot of work has been done on the server.")
print("\nDoing the same again but every thread now has its own proxy.")
print("Starting 10 threads with different proxies that all call the work() method.")
proxy.reset_work()
stop = False
threads = []
for i in range(10):
proxy = Pyro4.core.Proxy(proxy._pyroUri) # create a new proxy
thread = threading.Thread(target=myThread2, args=[proxy])
thread.setDaemon(False)
threads.append(thread)
thread.start()
print("waiting 5 seconds")
start = time.time()
time.sleep(5)
print("waiting until threads have stopped...")
stop = True
for thread in threads:
thread.join()
duration = int(time.time() - start)
print("--> time until everything completed: %.2f" % duration)
print("--> work done on the server: %d" % proxy.get_work_done())
print("you can see that this time the 10 threads didn't have to wait for each other,")
print("and that they got a lot more work done because they really ran in parallel.")
|
