-
Notifications
You must be signed in to change notification settings - Fork 31
Expand file tree
/
Copy pathspinner_thread.py
More file actions
executable file
·47 lines (34 loc) · 1.03 KB
/
spinner_thread.py
File metadata and controls
executable file
·47 lines (34 loc) · 1.03 KB
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
#!/usr/bin/env python3
# spinner_thread.py
# credits: Adapted from Michele Simionato's
# multiprocessing example in the python-list:
# https://mail.python.org/pipermail/python-list/2009-February/538048.html
import threading
import itertools
import time
def spin(msg, done): # <1>
for char in itertools.cycle('|/-\\'):
status = char + ' ' + msg
print('\r' + status, end='', flush=True)
if done.wait(.1): # <2>
break # <3>
print('\r', end='')
def slow_function(): # <4>
# pretend waiting a long time for I/O
time.sleep(3) # <5>
return 42
def supervisor(): # <6>
done = threading.Event() # <7>
spinner = threading.Thread(
target=spin, args=('thinking!', done)) # <8>
print('spinner object:', spinner) # <9>
spinner.start() # <10>
result = slow_function() # <11>
done.set() # <12>
spinner.join() # <13>
return result
def main():
result = supervisor() # <14>
print('Answer:', result)
if __name__ == '__main__':
main()