code: def current_jobs(self):
      
  
      jobs = []
      with synchronized(self.__queue):
        for worker in self.__threads:
          with synchronized(worker):
            if worker.current:
              jobs.append(worker.current)
      return jobs
docs: Returns a snapshot of the Jobs that are currently being processed by the
      ThreadPool. These jobs can not be found in the #pending_jobs() list.