whatamithinking-aiotools 1.0.2

WhatAmIThinking-aiotools

asyncio tools

Table of Contents

• WhatAmIThinking-aiotools
• Table of Contents
• Shields
  • Problems
  • Solutions
• Locks
  • Problems
  • Solutions

Shields

Problems

The built-in asyncio.shield() function has the following issues:

• if the current task is cancelled, execution flow will continue but the shielded task will keep running in the background, making program flow difficult to debug and buggy in cases where resources needed by that task are destroyed after that task completes, creating a sort of race condition.
  • the solution of wrapping the task you are running within a task works but is inefficient and slow because you have to wait for a cycle of the loop before you can get your result back
• code has to be awkwardly chopped up into blocks, because some parts may need to be shielded while others should not be.
  • there is no solution to this using the stdlib alone, except to break into multiple functions which is awkward and hard to follow

Solutions

Use shield_scope() context manager to shield blocks of code from execution The task cancellation is delayed until the scope exits, after which asyncio.CancelledError will be raised on the next await

Use asyncio.get_event_loop().set_task_factory(aiotools.create_shieldable_task) to enable shielding to work properly. This works by creating a custom python asyncio task class.

Locks

Problems

• Cannot re-enter asyncio.Lock
  • code has to instead be awkwardly chopped up to avoid re-entering the same lock and getting deadlocked. this again is hard to follow.

Solutions

Use RLock which is just a subclass of asyncio.Lock with support for re-entrance