private final FrmReconciliationService frmReconciliationService;
private final AlarmAgent alarmAgent;
private final NodeListener nodeListener;
- private final int threadPoolSize = 10;
private final Map<String, ReconciliationState> reconciliationStates;
- private ExecutorService executor = Executors.newWorkStealingPool(threadPoolSize);
+ private ExecutorService executor = Executors.newWorkStealingPool(10);
public ReconciliationServiceImpl(final DataBroker broker, final FrmReconciliationService frmReconciliationService,
final AlarmAgent alarmAgent, final NodeListener nodeListener,