-
Hello, I plan to have many concurrent periodic jobs running at the same time essentially for parallel processing purposes. Thanks, |
Beta Was this translation helpful? Give feedback.
Replies: 1 comment
-
Hi at time t0 => we enqueued a job with period p (in seconds for example) This process continues unless you delete the job manually. You can delete a periodic job same as other job. |
Beta Was this translation helpful? Give feedback.
Hi
Periodic jobs works like this
at time t0 => we enqueued a job with period p (in seconds for example)
t0+p => on message consumption(before calling listener method) a new job is scheduled to t0+p+p (even if there's a delay in message consumption new job would be scheduled for t0+2p)
to+3p => on message consumption(before calling listener method) a new job is scheduled to t0+3p (even if there's a delay in message consumption new job would be scheduled for t0+2p)
This process continues unless you delete the job manually. You can delete a periodic job same as other job.
rqueue/rqueue-core/src/main/java/com/github/sonus21/rqueue/listener/RqueueExecutor.java
Line 325 in 2fdbbe7