Выполнение процессора, когда блоки Async завершают выполнение

Question

В mule внутри родительского потока я использовал три вспомогательных потока, каждый подтолк выполняется в aysnchronous block. Я хотел выполнить процессор, как только каждый из подпотоков завершил обработку. Может кто-то пролить свет на то, как это можно сделать.

Answer 1

Для реализации такого типа привязки вил с помощью Mule вам необходимо использовать обработчики сообщений .

Подробнее о подходе здесь: http://blogs.mulesoft.org/aggregation-with-mule-fork-and-join-pattern/

Answer 2

Или, если вы хотите, чтобы избежать накладных расходов на VM очереди в вы можете сделать это this way

Ключ использует который имеет логику для выполнения fork- join

<processor-chain> 
<custom-processor class="com.ricston.processor.ParallelMessageProcessor" doc:name="ParallelMessageProcessor"> 
<spring:property name="processors"> 
<spring:list> 
<spring:ref bean="lookupWs1"/> 
<spring:ref bean="lookupWs2"/> 
</spring:list> 
</spring:property> 
<spring:property name="maxActive" value="100"/> 
</custom-processor> 
<combine-collections-transformer /> 
</processor-chain>