-
Notifications
You must be signed in to change notification settings - Fork 0
/
example_async.py
62 lines (47 loc) · 1.23 KB
/
example_async.py
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
import asyncio
import time
def prime_generator():
n: int = 2
primes: set = set()
while True:
test = [p for p in primes if n % p == 0]
if not any(test):
primes.add(n)
yield n
n += 1
async def prime_factors(n):
print(f'Starting processing for {n}')
factors = {}
primes = prime_generator()
v = n
for p in primes:
if v <= 1:
break
while v > 1 and v % p == 0:
if p not in factors:
factors[p] = 1
else:
factors[p] += 1
v /= p
await asyncio.sleep(0)
print(f'Finished processing for {n}')
return factors
async def process_value(n):
factors = await prime_factors(n)
print(f'>> Factors of {n}: {factors}')
def main():
start = time.clock()
loop: asyncio.AbstractEventLoop = asyncio.get_event_loop()
task = asyncio.gather(
process_value(223976),
process_value(1042751),
process_value(1209429),
process_value(3939039),
process_value(5380794)
)
loop.run_until_complete(task)
loop.close()
end = time.clock()
print(f'Time taken: {end - start} seconds')
if __name__ == '__main__':
main()