@Porana123: @GotoFinal: no poprostu te 4 pierwsze są dodawane do ExecutorService ten while robi się 4 razy bo tyle aktualnie jest procesów, ale ten co się po sekundzie dodaje "1666" to już nie wchodzi do tego while, odkryłem w międzyczasie że są 2 kolejki jedna moja queue a druga to ta wewnątrz ExecutorService
@Fachmann: juzywaj metody poll(), robisz pętle np while tak długo aż poll() coś zwraca. Pamiętaj że poll od razu usuwa też ten element, więc daj go koniecznie do zmiennej.
@Fachmann: 1. zamien queue na jakąś blokującą, 2. pętle zamien na np. while(!Thread.currentThread().isInterrupted()){queue.take(); ...} i umiesc w nowym wątku.
1. zamien queue na jakąś blokującą,
2. pętle zamien na np. while(!Thread.currentThread().isInterrupted()){queue.take(); ...} i umiesc w nowym wątku.