Python/asyncio - Revision history

Tacoball at 08:40, 21 June 2021

2021-06-21T08:40:36Z

← Older revision		Revision as of 08:40, 21 June 2021
Line 1:		Line 1:
			== functions ==

	https://docs.python.org/3/library/asyncio-task.html#running-an-asyncio-program		https://docs.python.org/3/library/asyncio-task.html#running-an-asyncio-program

Line 33:		Line 35:
	\|-		\|-
	\| asyncio.start_unix_server() \|\| \|\|		\| asyncio.start_unix_server() \|\| \|\|
			\|-
			\| async.create_subprocess_shell() \|\| \|\|
			\|-
			\| async.create_subprocess_exec() \|\| \|\|
	\|}		\|}

Tacoball at 08:36, 21 June 2021

2021-06-21T08:36:41Z

← Older revision		Revision as of 08:36, 21 June 2021
Line 25:		Line 25:
	\|-		\|-
	\| asyncio.all_tasks() \|\| \|\| set(task)		\| asyncio.all_tasks() \|\| \|\| set(task)
			\|-
			\| asyncio.open_connection() \|\| \|\|
			\|-
			\| asyncio.start_server() \|\| \|\|
			\|-
			\| asyncio.open_unix_connection() \|\| \|\|
			\|-
			\| asyncio.start_unix_server() \|\| \|\|
	\|}		\|}

Tacoball at 08:11, 21 June 2021

2021-06-21T08:11:13Z

← Older revision		Revision as of 08:11, 21 June 2021
Line 5:		Line 5:
	\|-		\|-
	\| asyncio.run() \|\| coroutine \|\|		\| asyncio.run() \|\| coroutine \|\|
	\|-
	~~\| asyncio.create_task() \|\| coroutine \|\| task~~
	\|-		\|-
	\| asyncio.gather() \|\| *awaitable \|\| coroutine		\| asyncio.gather() \|\| *awaitable \|\| coroutine
Line 21:		Line 19:
	\|-		\|-
	\| asyncio.run_coroutine_threadsafe() \|\| coroutine \|\| future		\| asyncio.run_coroutine_threadsafe() \|\| coroutine \|\| future
			\|-
			\| asyncio.create_task() \|\| coroutine \|\| task
	\|-		\|-
	\| asyncio.current_task() \|\| \|\| task		\| asyncio.current_task() \|\| \|\| task

Tacoball at 08:10, 21 June 2021

2021-06-21T08:10:08Z

← Older revision		Revision as of 08:10, 21 June 2021
Line 22:		Line 22:
	\| asyncio.run_coroutine_threadsafe() \|\| coroutine \|\| future		\| asyncio.run_coroutine_threadsafe() \|\| coroutine \|\| future
	\|-		\|-
	\| asyncio.current_task() \|\| \|\| ~~Task~~		\| asyncio.current_task() \|\| \|\| task
	\|-		\|-
	\| asyncio.all_tasks() \|\| \|\| ~~Set~~(~~Task~~)		\| asyncio.all_tasks() \|\| \|\| set(task)
	\|}		\|}

Tacoball at 08:09, 21 June 2021

2021-06-21T08:09:17Z

← Older revision		Revision as of 08:09, 21 June 2021
Line 6:		Line 6:
	\| asyncio.run() \|\| coroutine \|\|		\| asyncio.run() \|\| coroutine \|\|
	\|-		\|-
	\| asyncio.create_task() \|\| ~~Task~~ \|\| ~~coroutine~~		\| asyncio.create_task() \|\| coroutine \|\| task
	\|-		\|-
	\| asyncio.gather() \|\| *awaitable \|\| coroutine		\| asyncio.gather() \|\| *awaitable \|\| coroutine

Tacoball at 08:08, 21 June 2021

2021-06-21T08:08:52Z

← Older revision		Revision as of 08:08, 21 June 2021
Line 4:		Line 4:
	! function \|\| arg \|\| return		! function \|\| arg \|\| return
	\|-		\|-
	\| asyncio.run() \|\| coroutine \|\| ~~None~~		\| asyncio.run() \|\| coroutine \|\|
	\|-		\|-
	\| asyncio.create_task() \|\| Task \|\| coroutine		\| asyncio.create_task() \|\| Task \|\| coroutine

Tacoball at 08:08, 21 June 2021

2021-06-21T08:08:13Z

← Older revision		Revision as of 08:08, 21 June 2021
Line 1:		Line 1:
			https://docs.python.org/3/library/asyncio-task.html#running-an-asyncio-program

			{\| class="wikitable"
			! function \|\| arg \|\| return
			\|-
			\| asyncio.run() \|\| coroutine \|\| None
			\|-
			\| asyncio.create_task() \|\| Task \|\| coroutine
			\|-
			\| asyncio.gather() \|\| *awaitable \|\| coroutine
			\|-
			\| asyncio.sleep() \|\| float \|\| coroutine
			\|-
			\| asyncio.shield() \|\| awaitable \|\| awaitable
			\|-
			\| asyncio.wait_for() \|\| awaitable \|\| coroutine
			\|-
			\| asyncio.wait() \|\| awaitable \|\| coroutine
			\|-
			\| asyncio.to_thread() \|\| function \|\| coroutine
			\|-
			\| asyncio.run_coroutine_threadsafe() \|\| coroutine \|\| future
			\|-
			\| asyncio.current_task() \|\| \|\| Task
			\|-
			\| asyncio.all_tasks() \|\| \|\| Set(Task)
			\|}

	== Topics ==		== Topics ==

Tacoball at 19:22, 18 June 2021

2021-06-18T19:22:39Z

← Older revision		Revision as of 19:22, 18 June 2021
Line 1:		Line 1:
	## Topics		== Topics ==

	* await		* await

Tacoball at 19:22, 18 June 2021

2021-06-18T19:22:25Z

← Older revision		Revision as of 19:22, 18 June 2021
Line 1:		Line 1:
			## Topics

			* await
			* Lock
			* Event
			* Condition
			* Semaphore
			* Queue
			* Subprocess
			* Cross loop IPC

	<source lang="python3">		<source lang="python3">
	import asyncio		import asyncio

Tacoball at 19:10, 18 June 2021

2021-06-18T19:10:13Z

← Older revision		Revision as of 19:10, 18 June 2021
Line 43:		Line 43:

	asyncio.run(main())		asyncio.run(main())
			</source>

			<source lang="python3">
			'''
			I/O test for asyncio.Queue

			QSIZE = 300000
			QFILL = 300000
			FORCE_SWITCH = False

			enqueue(): Put 100000 items.
			enqueue(): Put 200000 items.
			enqueue(): Put 300000 items.
			dequeue(): Get 100000 items.
			dequeue(): Get 200000 items.
			dequeue(): Get 300000 items.
			asynio.Queue put() and get() 300000 items.
			0.67 seconds, 448386.61 items per second.

			QSIZE = 100000
			QFILL = 300000
			FORCE_SWITCH = False

			enqueue(): Put 100000 items.
			dequeue(): Get 100000 items.
			enqueue(): Put 200000 items.
			dequeue(): Get 200000 items.
			enqueue(): Put 300000 items.
			dequeue(): Get 300000 items.
			asynio.Queue put() and get() 300000 items.
			0.68 seconds, 442956.25 items per second.

			QSIZE = 300000
			QFILL = 300000
			FORCE_SWITCH = True

			enqueue(): Put 100000 items.
			dequeue(): Get 100000 items.
			enqueue(): Put 200000 items.
			dequeue(): Get 200000 items.
			enqueue(): Put 300000 items.
			dequeue(): Get 300000 items.
			asynio.Queue put() and get() 300000 items.
			0.68 seconds, 440712.40 items per second.
			'''

			import asyncio
			import time

			QSIZE = 300000
			QFILL = 300000
			FORCE_SWITCH = False
			OUTPUT_INTERVAL = 100000
			TICK = {
			'security_id': '2330.TW',
			'open': 599.05,
			'close': 600.15,
			'high': 612.05,
			'low': 593.75,
			'5d': 595.25,
			'10d': 590.85,
			'20d': 588.65,
			'60d': 550.50,
			'120d': 510.45,
			'240d': 450.15
			}

			async def enqueue():
			global q
			i = 0
			while i < QFILL:
			await q.put(TICK.copy())
			i += 1
			if i % OUTPUT_INTERVAL == 0:
			print('enqueue(): Put %d items.' % i)
			if FORCE_SWITCH:
			await asyncio.sleep(0)

			async def dequeue():
			global q
			i = 0
			while i < QFILL:
			await q.get()
			i += 1
			if i % OUTPUT_INTERVAL == 0:
			print('dequeue(): Get %d items.' % i)
			if FORCE_SWITCH:
			await asyncio.sleep(0)

			async def main():
			global q
			q = asyncio.Queue(maxsize=QSIZE)
			begin = time.time()
			await asyncio.gather(dequeue(), enqueue())
			elapsed = time.time() - begin
			print('asynio.Queue put() and get() %d items.' % QFILL)
			print('%.2f seconds, %.2f items per second.' % (elapsed, QFILL / elapsed))

			if __name__ == '__main__':
			asyncio.run(main())
	</source>		</source>