EJB @ Schedule poczekaj do zakończenia metody

Jeśli tylko jeden timer może być aktywny w tym samym czasie, istnieje kilka rozwiązań.

Po pierwsze @Timer powinny być prawdopodobnie obecne na @Singleton. W Singletonie metody są domyślnie zablokowane zapisem, więc kontener zostanie automatycznie zablokowany podczas próby wywołania metody timer, gdy nadal jest w niej aktywność.

W zasadzie wystarczy:

@Singleton
public class TimerBean {

    @Schedule(second= "*/5", minute = "*", hour = "*", persistent = false)
    public void atSchedule() throws InterruptedException {

        System.out.println("Called");
        Thread.sleep(10000);
    }
}

atSchedule jest domyślnie zablokowany zapis i zawsze może być w nim aktywny tylko jeden wątek, w tym wywołania inicjowane przez kontener.

Po zablokowaniu, kontener może jednak ponownie spróbować timera, więc aby temu zapobiec, należy użyć blokady odczytu i delegować ją do drugiego bean (druga bean jest potrzebna, ponieważ EJB 3.1 nie pozwala na aktualizację blokady odczytu do blokady zapisu).

The timer bean:

@Singleton
public class TimerBean {

    @EJB
    private WorkerBean workerBean;

    @Lock(READ)
    @Schedule(second = "*/5", minute = "*", hour = "*", persistent = false)
    public void atSchedule() {

        try {
            workerBean.doTimerWork();
        } catch (Exception e) {
            System.out.println("Timer still busy");
        }
    }

}

Pracownik:

@Singleton
public class WorkerBean {

    @AccessTimeout(0)
    public void doTimerWork() throws InterruptedException {
        System.out.println("Timer work started");
        Thread.sleep(12000);
        System.out.println("Timer work done");
    }
}

To prawdopodobnie nadal wyświetli hałaśliwy wyjątek w dzienniku, więc bardziej gadatliwym, ale cichszym rozwiązaniem jest użycie explicit boolean:

The timer bean:

@Singleton
public class TimerBean {

    @EJB
    private WorkerBean workerBean;

    @Lock(READ)
    @Schedule(second = "*/5", minute = "*", hour = "*", persistent = false)
    public void atSchedule() {
        workerBean.doTimerWork();
    }

}

Pracownik:

@Singleton
public class WorkerBean {

    private AtomicBoolean busy = new AtomicBoolean(false);

    @Lock(READ)
    public void doTimerWork() throws InterruptedException {

        if (!busy.compareAndSet(false, true)) {
            return;
        }

        try {
            System.out.println("Timer work started");
            Thread.sleep(12000);
            System.out.println("Timer work done");
        } finally {
            busy.set(false);
        }
    }

}

Istnieje kilka innych możliwych wariantów, np. możesz delegować busy check do interceptor, lub wstrzyknąć singleton, który zawiera tylko boolean do timera Bean, i sprawdzić, że boolean tam, itp.