52 lines
1.3 KiB
Python
Executable File
52 lines
1.3 KiB
Python
Executable File
#!/usr/bin/env python3
|
|
|
|
# spinner_curio.py
|
|
|
|
# credits:
|
|
# Example from the book Fluent Python by Luciano Ramalho inspired by
|
|
# Michele Simionato's multiprocessing example in the python-list:
|
|
# https://mail.python.org/pipermail/python-list/2009-February/538048.html
|
|
# ported to use David Beazley's `curio` library:
|
|
# https://github.com/dabeaz/curio
|
|
|
|
import curio
|
|
import itertools
|
|
import sys
|
|
|
|
|
|
async def spin(msg): # <1>
|
|
write, flush = sys.stdout.write, sys.stdout.flush
|
|
for char in itertools.cycle('|/-\\'):
|
|
status = char + ' ' + msg
|
|
write(status)
|
|
flush()
|
|
write('\x08' * len(status))
|
|
try:
|
|
await curio.sleep(.1) # <2>
|
|
except curio.CancelledError: # <3>
|
|
break
|
|
write(' ' * len(status) + '\x08' * len(status))
|
|
|
|
|
|
async def slow_function(): # <4>
|
|
# pretend waiting a long time for I/O
|
|
await curio.sleep(3) # <5>
|
|
return 42
|
|
|
|
|
|
async def supervisor(): # <6>
|
|
spinner = await curio.spawn(spin('thinking!')) # <7>
|
|
print('spinner object:\n ', repr(spinner)) # <8>
|
|
result = await slow_function() # <9>
|
|
await spinner.cancel() # <10>
|
|
return result
|
|
|
|
|
|
def main():
|
|
result = curio.run(supervisor) # <11>
|
|
print('Answer:', result)
|
|
|
|
|
|
if __name__ == '__main__':
|
|
main()
|