48 lines
1010 B
Python
48 lines
1010 B
Python
|
"""
|
|||
|
|
协程（coroutine）- 可以在需要时进行切换的相互协作的子程序
|
|||
|
|
"""
|
|||
|
|
import asyncio
|
|||
|
|
|
|||
|
|
from example15 import is_prime
|
|||
|
|
|
|||
|
|
|
|||
|
|
def num_generator(m, n):
|
|||
|
|
"""指定范围的数字生成器"""
|
|||
|
|
yield from range(m, n + 1)
|
|||
|
|
|
|||
|
|
|
|||
|
|
async def prime_filter(m, n):
|
|||
|
|
"""素数过滤器"""
|
|||
|
|
primes = []
|
|||
|
|
for i in num_generator(m, n):
|
|||
|
|
if is_prime(i):
|
|||
|
|
print('Prime =>', i)
|
|||
|
|
primes.append(i)
|
|||
|
|
|
|||
|
|
await asyncio.sleep(0.001)
|
|||
|
|
return tuple(primes)
|
|||
|
|
|
|||
|
|
|
|||
|
|
async def square_mapper(m, n):
|
|||
|
|
"""平方映射器"""
|
|||
|
|
squares = []
|
|||
|
|
for i in num_generator(m, n):
|
|||
|
|
print('Square =>', i * i)
|
|||
|
|
squares.append(i * i)
|
|||
|
|
|
|||
|
|
await asyncio.sleep(0.001)
|
|||
|
|
return squares
|
|||
|
|
|
|||
|
|
|
|||
|
|
def main():
|
|||
|
|
"""主函数"""
|
|||
|
|
loop = asyncio.get_event_loop()
|
|||
|
|
future = asyncio.gather(prime_filter(2, 100), square_mapper(1, 100))
|
|||
|
|
future.add_done_callback(lambda x: print(x.result()))
|
|||
|
|
loop.run_until_complete(future)
|
|||
|
|
loop.close()
|
|||
|
|
|
|||
|
|
|
|||
|
|
if __name__ == '__main__':
|
|||
|
|
main()
|