Method weakref_cb

Lib/concurrent/futures/process.py:298–303

(_,
                       thread_wakeup=self.thread_wakeup,
                       mp_util_debug=mp.util.debug)

        # will wake up the queue management thread so that it can terminate
        # if there is no pending work item.
        def weakref_cb(_,
                       thread_wakeup=self.thread_wakeup,
                       mp_util_debug=mp.util.debug):
            mp_util_debug('Executor collected: triggering callback for'
                          ' QueueManager wakeup')
            thread_wakeup.wakeup()

        self.executor_reference = weakref.ref(executor, weakref_cb)