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
|
import time
import threading
from Pyro5.api import Proxy
serv = Proxy("PYRONAME:example.servertypes")
print("--------------------------------------------------------------")
print(" This part is independent of the type of the server. ")
print("--------------------------------------------------------------")
print("Calling 5 times oneway method. Should return immediately.")
serv.reset()
begin = time.time()
serv.onewaydelay()
serv.onewaydelay()
serv.onewaydelay()
serv.onewaydelay()
serv.onewaydelay()
print("Done with the oneway calls.")
completed = serv.getcount()
print("Number of completed calls in the server: %d" % completed)
print(" (this should be 0, because all 5 calls are still busy in the background)")
if completed > 0:
raise SystemExit("error: oneway calls should run in the background!")
print()
print("Calling normal delay 5 times. They will all be processed by the same server thread because we're using the same proxy.")
r = serv.delay()
print(" call processed by: %s" % r)
r = serv.delay()
print(" call processed by: %s" % r)
r = serv.delay()
print(" call processed by: %s" % r)
r = serv.delay()
print(" call processed by: %s" % r)
r = serv.delay()
print(" call processed by: %s" % r)
time.sleep(2)
print("Number of completed calls in the server: %d" % serv.getcount())
print(" (this should be 10, because by now the 5 oneway calls have completed as well)")
serv.reset()
print("\n--------------------------------------------------------------")
print(" This part depends on the type of the server. ")
print("--------------------------------------------------------------")
print("Creating 5 threads that each call the server at the same time.")
serverconfig = serv.getconfig()
if serverconfig["SERVERTYPE"] == "thread":
print("Servertype is thread. All calls will run in parallel.")
print("The time this will take is 1 second (every thread takes 1 second in parallel).")
print("You will see that the requests are handled by different server threads.")
elif serverconfig["SERVERTYPE"] == "multiplex":
print("Servertype is multiplex. The calls will need to get in line.")
print("The time this will take is 5 seconds (every thread takes 1 second sequentially).")
print("You will see that the requests are handled by a single server thread.")
else:
print("Unknown servertype")
def func(uri):
# This will run in a thread. Create a proxy just for this thread:
with Proxy(uri) as p:
processed = p.delay()
print("[ thread %s called delay, processed by: %s ] " % (threading.current_thread().name, processed))
serv._pyroBind() # simplify the uri
threads = []
for i in range(5):
t = threading.Thread(target=func, args=[serv._pyroUri])
t.daemon = True
threads.append(t)
t.start()
print("Waiting for threads to finish:")
for t in threads:
t.join()
print("Done. Number of completed calls in the server: %d" % serv.getcount())
|
