Fachmann
Treść przeznaczona dla osób powyżej 18 roku życia...
1
  • Najlepsze
  • Wszystkie komentarze
GotoFinal
@Fachmann sypie się? tzn? Że z powodu wątków? to użyj wtedy np ConcurrentLinkedDeque zamiast linked list.
0
P.....3
P.....3
@Fachmann: Co ci się tu sypie? Dodaje nowe do kolejki i jest ok, chyba że ty oczekujesz czegoś konkretnego i nie napisałeś czego.
0
Fachmann
@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
0
GotoFinal
@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.
0
Fachmann
nie tu leży problem potrzebowałbym procesu którego zadaniem jest przechwytywanie queue i wysyłanie tego do ExecutorService
0
afe1
@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.
0
P.....3
P.....3
@Fachmann: http://pastebin.com/HMzgduWV Obczaj czy o takei cos ci chodzilo, oczywiscie kod jest straszny ale nie o to sie tu rozchodzi ( ͡° ʖ̯ ͡°)
0