def finalize(self):
    self._send_message(('finalize', None))
    for worker in self._workers:
        worker.join()
def finalize(self):
    self._send_message(('finalize', None))
    for worker in self._workers:
        worker.join()