code: def notify_all(self):
      assert self._lock._semlock._is_mine(), "lock is not owned"
      assert not self._wait_semaphore.acquire(False)
  
      # to take account of timeouts since last notify*() we subtract
      # woken_count from sleeping_count and rezero woken_count
      while self._woken_count.acquire(False):
          res = self._sleeping_count.acquire(False)
          assert res
  
      sleepers = 0
      while self._sleeping_count.acquire(False):
          self._wait_semaphore.release()  # wake up one sleeper
          sleepers += 1
  
      if sleepers:
          for _ in range(sleepers):
              self._woken_count.acquire()  # wait for a sleeper to wake
  
          # rezero wait_semaphore in case some timeouts just happened
          while self._wait_semaphore.acquire(False):
              pass
  
imports: import os
  import sys
  import tempfile
  import threading
  import _multiprocessing
  from time import time
  from multiprocessing import process, util
  from multiprocessing.context import assert_spawning
  from .None import resource_tracker
label_desc: Use image node_id 10 for calling the Condition obj's underlying member method code with example usage: obj.notify_all() without return types