Sleeping tasks are now awoken after the parent crashes
This commit is contained in:
parent
724b5c98ba
commit
727848ada8
|
@ -666,6 +666,8 @@ class FIFOKernel:
|
||||||
if task is not self.current_task:
|
if task is not self.current_task:
|
||||||
task.joiners.add(self.current_task)
|
task.joiners.add(self.current_task)
|
||||||
if task.done():
|
if task.done():
|
||||||
|
for joiner in task.joiners:
|
||||||
|
self.paused.discard(joiner)
|
||||||
self.run_ready.extend(task.joiners)
|
self.run_ready.extend(task.joiners)
|
||||||
|
|
||||||
def spawn(self, func: Callable[..., Coroutine[Any, Any, Any]], *args, **kwargs):
|
def spawn(self, func: Callable[..., Coroutine[Any, Any, Any]], *args, **kwargs):
|
||||||
|
|
Reference in New Issue