Mam scheduledexecutorservice, który wykonuje zadanie co sekundę dopóki nie to wykonane poprawnie. Czasami zajmuje to 5 sekund czasami 15 sekund. Do tego executora co pewnien czas wysyłane są nowe zadania przez scheduledAtFixedRate.
Chciałbym, żeby scheduledexecutorservice zajmował się kolejnym zadaniem dopiero gdy skończy poprzednie. Nie może być tak, że zadania wykonywane są równoczesne. Jak zaimplementować kolejkę?
- Rejestracja:ponad 4 lata
- Ostatnio:około 2 miesiące
- Postów:26
0
Java 
Spring 
- Rejestracja:prawie 9 lat
- Ostatnio:5 miesięcy
- Lokalizacja:Futurama
- Postów:887
1
Mam scheduledexecutorservice, który wykonuje zadanie co sekundę dopóki nie to wykonane poprawnie.
Ale że co? To chyba średnio po polsku xd
Jak zaimplementować kolejkę?
Polecam wybrać coś z "Direct Known Subclasses" co będzie odpowiadać Twoim potrzebom.
- Rejestracja:ponad 4 lata
- Ostatnio:około 2 miesiące
- Postów:26
0
W zadaniu które przekazuje do scheduleAtFixedRate sprawdzam pewne warunki, gdy zostaną spełnione to wywołuję inną funkcję i uznaje że zostało to wykonane poprawnie.
Uruchomiam dużo scheduleAtFixedRate w różnym czasie i chcę żeby to było wykonywane po kolei a nie na raz.
Jak to osiągnąć?
Burdzi0 napisał(a):
Mam scheduledexecutorservice, który wykonuje zadanie co sekundę dopóki nie to wykonane poprawnie.
Ale że co? To chyba średnio po polsku xd
Jak zaimplementować kolejkę?
Polecam wybrać coś z "Direct Known Subclasses" co będzie odpowiadać Twoim potrzebom.
edytowany 3x, ostatnio: the_dude777
- Rejestracja:prawie 5 lat
- Ostatnio:5 miesięcy
- Postów:2420
0
Z docs:
While this class inherits from ThreadPoolExecutor, a few of the inherited tuning methods are not useful for it. In particular, because** it acts as a fixed-sized pool using corePoolSize threads **and an unbounded queue, adjustments to maximumPoolSize have no useful effect. Additionally, it is almost never a good idea to set corePoolSize to zero or use allowCoreThreadTimeOut because this may leave the pool without threads to handle tasks once they become eligible to run.
https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ScheduledThreadPoolExecutor.html
edytowany 1x, ostatnio: 99xmarcin
- Rejestracja:ponad 17 lat
- Ostatnio:28 dni
- Lokalizacja:Kraków
0
mozesz np stworzyc tabele w db w ktorej po uruchomieniu zadania bedziesz dodawal rekord aktualnie wykonywanego zadania, do tego powinna byc flaga, ze aktualnie zadanie sie wykonuje oraz kolumna z czasem zakonczenia wykonywania zadania(popoprawnym zakonczeniu zadania rekord jest usuwany z tabeli). jesli uruchmisz zbyt szybko kolejne zadanie i sprawdzisz w tabeli ze nadal jest ono wykonywane poniewaz zostalo wczesniej uruchomione to nie jest ono uruchamiane kolejny raz. jest to przydatne rozwiazanie tez w sytuacji, gdy apke instalujesz na kilku nodeach (serwerach), wowczas sie zabezpieczasz przezd tym, aby dane zadanie bylo wykonywane tylko przez jedna instancje jeden raz, aby nie dublowaly sie te same wywolania.
pozdr
Burdzi0
Przeraża mnie ta strona w stopce :O
RequiredNickname
takie strzelanie do bazy nie jest raczej dobre ani pod kątem wydajności ani pracy wielowątkowej.
pvw
@RequiredNickname: to sie zgadza, to tylko jedna z potencjalnych opcji zaleznie od tego jakie sa wymagania dokladne
- Rejestracja:prawie 6 lat
- Ostatnio:około 2 lata
- Postów:49
0
the_dude777 napisał(a):
Chciałbym, żeby scheduledexecutorservice zajmował się kolejnym zadaniem dopiero gdy skończy poprzednie.
To dlatego wykorzystujesz scheduledAtFixedRate() zamiast schedule()?
ustawiasz aby dane zadanie wykonało się w konkretnym czasie, ale musisz poczekać aż inne wcześniejsze się wykonają, trochę to bez sensu.
Możesz ustawić tworzenie tego samego zadania przez inny Scheduler z stałym powtarzaniem, ale dodawać zadanie normalnie przez execute()
Stwórz sobie Executor z 1 jednego wątku i dodawaj tam zadania. Zadanie ma trwać tak długo jak dane warunki nie są spełnione aby go wykonać, możesz wykorzystać sleep() - brzydko ale będzie działać.
Nie napisałeś czy/w jaki sposób dane rozwiązanie ma się skalować - ile instancji, czy jest wspólna pula taksów oraz czy zadania mają być jakoś zapamiętane podczas restartu
edytowany 3x, ostatnio: ZabawnyNick
- Rejestracja:ponad 4 lata
- Ostatnio:około 2 lata
- Lokalizacja:Warszawa
- Postów:1092
2
W zadaniu które przekazuje do scheduleAtFixedRate sprawdzam pewne warunki, gdy zostaną spełnione to wywołuję inną funkcję i uznaje że zostało to wykonane poprawnie.
Ale odpalasz to w innym Executorze, tym samym czy jak?
Dokumentacja do scheduleAtFixedRate mówi:
Submits a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period; that is, executions will commence after initialDelay, then initialDelay + period, then initialDelay + 2 * period, and so on.
The sequence of task executions continues indefinitely until one of the following exceptional completions occur:
The task is explicitly cancelled via the returned future.
The executor terminates, also resulting in task cancellation.
An execution of the task throws an exception. In this case calling get on the returned future will throw ExecutionException, holding the exception as its cause.
Subsequent executions are suppressed. Subsequent calls to isDone() on the returned future will return true.
If any execution of this task takes longer than its period, then subsequent executions may start late, but will not concurrently execute.
Czyli jak wyżej chyba trzeba użyć Executors.newSingleThreadScheduledExecutor()