if i create poller with unlimited or big thread stack and short interval, then all threads for a short period of time will be executed and sleep on Poll method of AbstractPollingEndpoint which will sleep on inputChannel.receive().
So many instances pool's threads will be running and busyed at once without necessity. So i can't use single pool thread executor on many channels because if i uncorrect point these parametrs some poller could occupy all threads of pool, and another channels should be wait.
why there is not pollable consumer with scheme like this:
Code:public void poll() { for (;;) { pool.execute(new Handler(inputChannel.receive())); }


Reply With Quote