| 764 | } |
| 765 | |
| 766 | void ForceShutdown() { |
| 767 | // Force the upstream input node to unpause. Necessary to avoid deadlock when we |
| 768 | // terminate the process thread |
| 769 | queue_.ForceShutdown(); |
| 770 | } |
| 771 | |
| 772 | private: |
| 773 | // ExecBatch Sequencer |
no outgoing calls