Commitf6a171f

committed

spinner curio example in chapter 18b

1 parent2832de1 commitf6a171fCopy full SHA for f6a171f

File tree

+50

-1

lines changed

+50

-1

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-Sample code for Chapter 18 - "Concurrency with asyncio"`
	`1`	`+Refactored sample code for Chapter 18 - "Concurrency with asyncio"`
`2`	`2`
`3`	`3`	`From the book "Fluent Python" by Luciano Ramalho (O'Reilly, 2015)`
`4`	`4`	`http://shop.oreilly.com/product/0636920032519.do`

Lines changed: 49 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,49 @@`
	`1`	`+#!/usr/bin/env python3`
	`2`	`+`
	`3`	`+# spinner_curio.py`
	`4`	`+`
	`5`	`+# credits: Example by Luciano Ramalho inspired by`
	`6`	`+# Michele Simionato's multiprocessing example in the python-list:`
	`7`	`+# https://mail.python.org/pipermail/python-list/2009-February/538048.html`
	`8`	`+`
	`9`	`+importcurio`
	`10`	`+`
	`11`	`+importitertools`
	`12`	`+importsys`
	`13`	`+`
	`14`	`+`
	`15`	`+asyncdefspin(msg):# <1>`
	`16`	`+write,flush=sys.stdout.write,sys.stdout.flush`
	`17`	`+forcharinitertools.cycle('\|/-\\'):`
	`18`	`+status=char+' '+msg`
	`19`	`+write(status)`
	`20`	`+flush()`
	`21`	`+write('\x08'*len(status))`
	`22`	`+try:`
	`23`	`+awaitcurio.sleep(.1)# <2>`
	`24`	`+exceptcurio.CancelledError:# <3>`
	`25`	`+break`
	`26`	`+write(' 'len(status)+'\x08'len(status))`
	`27`	`+`
	`28`	`+`
	`29`	`+asyncdefslow_function():# <4>`
	`30`	`+# pretend waiting a long time for I/O`
	`31`	`+awaitcurio.sleep(3)# <5>`
	`32`	`+return42`
	`33`	`+`
	`34`	`+`
	`35`	`+asyncdefsupervisor():# <6>`
	`36`	`+spinner=awaitcurio.spawn(spin('thinking!'))# <7>`
	`37`	`+print('spinner object:\n ',repr(spinner))# <8>`
	`38`	`+result=awaitslow_function()# <9>`
	`39`	`+awaitspinner.cancel()# <10>`
	`40`	`+returnresult`
	`41`	`+`
	`42`	`+`
	`43`	`+defmain():`
	`44`	`+result=curio.run(supervisor)# <12>`
	`45`	`+print('Answer:',result)`
	`46`	`+`
	`47`	`+`
	`48`	`+if__name__=='__main__':`
	`49`	`+main()`

Comments

(0)