Chciałbym zaimplementować arrayblocking queue do swojego projektu. Program służy do nasłuchiwania zmian w folderze i używam biblioteki java.nio.file. Zmiany są zapisywane w bazie danych.
Za nasłuch w folderze odpowiedzialna jest klasa Notifer, do bazy wrzuca klasa NotiferDatabase.
W jaki sposób zaimplementować do projektu arrayblocking queue? Zacząłem od napisania:
BlockingQueue<NotifyFolder> queue = new ArrayBlockingQueue<>(10);
i dalej nie wiem jak to powinno wyglądać
@lion137 wyglada to tak: https://paste.ofcode.org/5ji5W2YJxx5tc6V2mXMFT8
To tu: https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ArrayBlockingQueue.html Masz dokumentację, np add(E e) wrzuca element na stos i zwraca true, jak było miejce, peek(), do podejrzenia co jest ostatnie na stosie, i tak dalej...
@lion137 https://paste.ofcode.org/3468zVNeyqwTi8kDSQdVEK8, takie cos juz dziala, ale obowiam sie ze czegos brakuje, powinienem dodac jeszcze runnable?
Do kolejki wrzucaj zadania, czyli w Twoim przypadku opis zmiany konkretnego pliku. Nie cały folder. Konsument będzie z kolejki pobierał informację o zmienionym pliku, a kolejka zwolni go z obowiązku śledzenia folderu. O to w tym chodzi.
Zarejestruj się i dołącz do największej społeczności programistów w Polsce.
Otrzymaj wsparcie, dziel się wiedzą i rozwijaj swoje umiejętności z najlepszymi.
Java