Usługa Watch Java 7 pętla odpytywania

Question

Byłem nieco zaskoczony, że usługa Watch powinna być wdrożona jako proces/wątek z pętlą odpytywania. Nie pamiętam żadnego innego API w Javie, które powinno to robić.

Czy nie byłoby lepiej zastosować go jako zestaw wywołań zwrotnych (słuchacze, obserwatorzy itp.)?

BTW - czy istnieje jakaś niezależna biblioteka, która robi to samo, ale używa modelu callback?

Answer 1

Apache Commons ma kilka usług do przeglądania plików, które moim zdaniem są znacznie lepsze niż te w Javie 7. Nie jestem pewien, czy używają one wywołań zwrotnych, ale są one w moim przekonaniu o wiele bardziej intuicyjne.

I tak, myślę, że model obserwatora byłby o wiele lepszy. Czytałem gdzieś, że nieco trudniej to zrobić z Javą, ponieważ działa ona przez maszynę wirtualną, i aby uzyskać słuchaczy na plikach, które trzeba rozmawiać bezpośrednio z systemem operacyjnym. Nie jestem jednak pewien szczegółów ani ważności tego.

Answer 2

Nie musisz używać odpytywania, możesz użyć funkcji WatchService.take(), która zwraca natychmiast po wystąpieniu zmiany. Tak, wymaga wątku, ale pojedynczy wątek może być używany do oglądania wielu obiektów. Łatwo więc zaimplementować singleton, który jest właścicielem obserwowanego wątku i umożliwia rejestrowanie wywołań zwrotnych dla każdego obiektu.

Jeśli chodzi o biblioteki stron trzecich, spójrz na Guava EventBus. Nie próbowałem tego i nie jestem pewien, czy to pasuje do twoich potrzeb.

Answer 3

buduję na Alexeis odpowiedź, ale nie sądzę, że było wystarczająco jasne ... spojrzeć na ten kod Przykład:

WatchService service = dir.getFileSystem().newWatchService(); 
WatchKey key = dir.register(service, ENTRY_CREATE, ENTRY_MODIFY, ENTRY_DELETE); 
System.out.println(key); 

for(;;) { 
    WatchKey k = service.take(); 
    System.out.println(k); 
    for(WatchEvent<?> ev:k.pollEvents()) { 
     System.out.println(ev.kind()); 
     if(ev.kind() == OVERFLOW) continue; 
     //TODO 
     System.out.println(ev.context()); 
    } 
    if(!k.reset()) break; 
} 

key.cancel(); 

Jeśli sprawdzić println(key)/println(k) wyjścia, zobaczysz, że ten sam obiekt jest wielokrotnie zwracany; take() zwraca za każdym razem, gdy klucz jest sygnalizowany, więc aby użyć wielu kluczy z tym samym WatchService, po prostu sprawdź, który klucz został zwrócony za każdym razem. Oznacza to również, że twoja pętla blokuje tak długo, jak długo klucz nie był sygnalizowany - dokładnie to, co chcesz.

the if(!k.reset()) break; również ma kluczowe znaczenie; o tym zapomniałem, pisząc swój komentarz na temat odpowiedzi Alexeisa. Moje założenie było takie, że take() jest wywoływane przez register(), a zatem żaden klucz nie powinien zostać zwrócony w moim kodzie użytkownika, ponieważ register() już go wykorzystał. Z tego błędnego założenia nie wiedziałem, co się właściwie dzieje.