code: def request_finished(key):
      
      with event_lock:
          threads[key] = threads[key][1:]
  
          if threads[key]:
              threads[key][0].run()
docs: Remove finished Thread from queue.
  
      :param key: data source key