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
|
#!/usr/bin/env python
from time import sleep
from circuits import Component, Debugger, Event, Timer, Worker, task
def factorial(n):
x = 1
for i in range(1, (n + 1)):
x = x * (i + 1)
sleep(1) # deliberate!
return x
class App(Component):
def init(self, *args, **kwargs):
Worker(process=True).register(self)
def foo(self):
print('Foo!')
def started(self, component):
self.fire(task(factorial, 3)) # async
self.fire(task(factorial, 5)) # async
self.fire(task(factorial, 7)) # async
self.fire(task(factorial, 10)) # async
self.fire(task(factorial, 11)) # async
self.fire(task(factorial, 11)) # async
self.fire(task(factorial, 12)) # async
self.fire(task(factorial, 14)) # async
Timer(1, Event.create('foo'), persist=True).register(self)
def task_success(self, function_called, factorial_result):
_func, argument = function_called
print(f'factorial({argument!s}) = {factorial_result:d}')
# Stop after the last and longest running task
if argument == 14:
self.stop()
if __name__ == '__main__':
app = App()
Debugger().register(app)
app.run()
|
