Wait-Notify для параллельной и последовательной обработки в Nifi - PullRequest
1 голос
/ 11 апреля 2019

У меня есть требование, когда мне нужно выполнять 4 задания параллельно, и когда одинаковые задания выполняются во всех 4 процессорах параллельно, а затем запустить следующий процессор, для этого я использовал wait-notify

Поток равен 4параллельные задания -> уведомить (идентификатор сигнала освобождения = $ {itemid}, имя счетчика сигналов = $ {processorname}) -> ожидание (идентификатор сигнала освобождения = $ {itemid}, счетчик целевого сигнала = 4) и отношение ожидания связано стот же процессор ожидания-> следующий процессор

Это работает впервые, но я заметил, что очередь ожидания не очищается даже после того, как выполнено условие подсчета целевого сигнала, и я полагаю, что это проблема, которая не работает для последующегопотоков.

Следует очистить очередь ожидания, как только критерии будут выполнены правильно?

...