Kolejka wątków

Witam
Od pewnego czasu zastanawia mnie temat kolejki, która będzie przechowywała wątki stworzone przez zdarzenia w programie, ale nie uruchomione. Kolejka działała by jak fifo, czyli po skończeniu wątek jest usuwany z kolejki, a następnie jest uruchamiany kolejny. Czy java dostarcza biblioteki dla takiego problemu? Czy posiada ktoś jakiś tutorial z przykładami?
Dzięki!!

Tak, poczytaj o ThreadPool, Executorach, itp.

po skończeniu wątek jest usuwany z kolejki, a następnie jest uruchamiany kolejny

Jaki to ma sens?

Potrzebujesz kolejki zadań, nie kolejki wątków.
Zadania możesz trzymać np. w ArrayBlockingQueue jako obiekty Runnable

Dzięki za podpowiedź.
Sens kolejki jest taki że: każdy wątek wysyła i odbiera z portu szeregowego pewne dane i wykonuje zapis w bazie danych. W przypadku kiedy jeden wątek nie zakończył zadania, a drugi został stworzony od zdarzenia np cyklicznego to zostanie umieszczony w takiej kolejce aby nie stworzyć konfliktu na porcie i nie pogubić <ort>hronologii ŁAPKI OBETNĘ TUŻ PRZY DUPIE ZA TAKIE BŁĘDY</ort> odczytu/zapisu z portu. Czy ma to sens... pewnie jakiś ma i zależy od częstości wywołań. Zapewne problem można inaczej rozwiązać.
Pozdr!

Executors.newSingleThreadExecutor() > http://docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/Executors.html#newSingleThreadExecutor%28%29 kolejkuje wywołania. Względnie można sięgnąć do kodu źródłowego, zobaczyć jak tworzony jest executor i podmienić kolejkę na taką jaka jest potrzebna.

marolo2 napisał(a)

Dzięki za podpowiedź.
Sens kolejki jest taki że: każdy wątek wysyła i odbiera z portu szeregowego pewne dane i wykonuje zapis w bazie danych. W przypadku kiedy jeden wątek nie zakończył zadania, a drugi został stworzony od zdarzenia np cyklicznego to zostanie umieszczony w takiej kolejce aby nie stworzyć konfliktu na porcie i nie pogubić hronologii odczytu/zapisu z portu. Czy ma to sens... pewnie jakiś ma i zależy od częstości wywołań. Zapewne problem można inaczej rozwiązać.
Pozdr!

Tak, jak pisałem - w kolejce powinny być zadania, nie wątki.
Wątki odczytujące z portu szeregowego powinny tworzyć zadania i umieszczać je w kolejce ArrayBlockingQueue. Dodatkowo istniałby jeden wątek, którego jedynym zadaniem byłoby pobieranie zadań z tej kolejki i ich procesowanie (np. zapis do bazy).

Najlepiej ten pojedynczy wątek stworzyć jako Executor, poprzez newSingleThreadExecutor (tak, jak sugeruje Koziołek).

@__krzysiek85, executory działają tak jak opisujesz. Tworzony jest wątek i kolejka Runnable do której wrzucane są obiekty przekazane przez użyszkodnika. Nie ma potrzeby tworzenia dodatkowego wątku, bo executor już go stworzył.

Tak, executory dzialaja jak mowi Koziolek i Krzysiu. Tak, one naprawde tak dzialaja.

Panowie, temat wyczerpany chyba?

Wydaje się być wyczerpany. Muszę się zapoznać z tymi mechanizmami.
Dzięki!
Pozdrawiam!