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 i in xrange(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 threading
  import os
  import sys
  from time import time, sleep
  import _multiprocessing
  from multiprocessing.process import current_process
  from multiprocessing.util import Finalize, register_after_fork, debug
  from multiprocessing.forking import assert_spawning, Popen
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