Многопроцессорное завершение работы BaseManager() занимает двадцать секунд

Question

Я использую BaseManager для совместного использования очереди с пулом рабочих процессов. Я вызываю start() на нем, чтобы менеджер работал в другом потоке.

В разделе shutdown() документация гласит: «Это доступно только в том случае, если для запуска процесса сервера был использован start()». Однако, если я вызываю shutdown(), процесс переднего плана будет блокировать процесс менеджера за двадцать секунд до завершения, каждый раз. Если я не вызываю shutdown(), процесс переднего плана уходит немедленно?

Что мне не хватает?

Также есть ли у кого-нибудь идеи, почему в документации говорится: «Это можно назвать несколько раз»? Почему вы отправляете несколько сигналов выключения в процесс менеджера?

Answer 1

Ожидает 20 секунд по дизайну. Пожалуйста, refer here для получения дополнительной информации

 process.join(timeout=0.2) 
     if process.is_alive(): 
      util.info('manager still alive') 
      if hasattr(process, 'terminate'): 
       util.info('trying to `terminate()` manager process') 
       process.terminate() 
       process.join(timeout=0.1) 
       if process.is_alive(): 
        util.info('manager still alive after terminate')