producer-consumer
Wątki producenta/konsumenta korzystające z kolejki
Chciałbym stworzyć jakiś rodzaj Producer/Consumer aplikacji do tworzenia wątków. Ale nie jestem pewien, jaki jest najlepszy s ... readQ.add();
}
public Object dequeue()
{
//do some stuff
return readQ.get();
}
}
I idź!
Blokowanie kolejki i wielowątkowy konsument, jak wiedzieć, kiedy zatrzymać
Mam jednego producenta wątków, który tworzy pewne obiekty zadań, które są następnie dodawane do ArrayBlockingQueue (który ma ... ak, to się zatrzymuje (teoretycznie więc możemy powiedzieć, że pracownik musi być uruchomiony, a kolejka nie może być pusta).
Kolejka Zadań jako tabela SQL z wieloma odbiorcami (PostgreSQL)
Mam typowy problem producent-konsument:
Wiele aplikacji producentów zapisuje żądania pracy do tabeli zadań w bazie danych P ... c zmiany drugiego.
Co mi umyka? Jak muszę napisać instrukcję SQL, aby wielu konsumentów nie rezerwowało tego samego rekordu?
Jak działa Zrównoważenie konsumentów w Kafka?
Gdy nowy konsument/brorker jest dodawany lub wyłączany, Kafka uruchamia operację równoważenia. Czy zmiana równowagi Kafki jest operacją blokującą? Czy konsumenci Kafki są blokowani podczas trwającej operacji przywracania równowagi?
Struktura danych jednego producenta, jednego konsumenta z podwójnym buforem w C++
Mam aplikację w $work, gdzie muszę poruszać się między dwoma wątkami w czasie rzeczywistym, które są zaplanowane na różnych c ... y, to gdzie?
Czy można to zrobić bez mutex? Może tylko z barierami pamięci lub instrukcjami CAS?
Czy można to zrobić lepiej?
boost C++ lock-Kolejka wolna od blokady vs Kolejka współdzielona
Jestem całkiem nowy w programowaniu wielowątkowym, po prostu znam najczęstszą kolejkę Producent-konsument.
Używam bibliotek b ... struktur danych typu lock free, a gdzie jest lepiej używać prostej implementacji opartej na 'mutex' i`condition_variables'?