将无状态bean注入runnable for ScheduledExecutorService

Question

我想在部署完GlassFish之后运行一些进程。进程将每小时运行一次，它包含通过无状态bean CarService使用下面的findAll（）从DB表中提取数据：

@PersistenceContext
private EntityManager em;

public List<Cars> findAll() {
    javax.persistence.criteria.CriteriaQuery cq = em.getCriteriaBuilder().createQuery();
    cq.select(cq.from(Cars.class));
    return em.createQuery(cq).getResultList();
}

@ManagedBean(eager=true)
@ApplicationScoped
public class ApplicationStateChange {

private ScheduledExecutorService scheduler;

@PostConstruct
public void init() {
    System.out.println("ejb init method called");
    scheduler = Executors.newScheduledThreadPool(2);
    scheduler.scheduleAtFixedRate(new ScheduleTask();, 15, 30, TimeUnit.SECONDS);
}

@PreDestroy
    public void destroy() {
        /* Shutdown stuff here */
        System.out.println("ejb destroy method called");
        scheduler.shutdownNow();
    }

public class ScheduleTask implements Runnable {

    @Inject
    CarService carService;
    private volatile ScheduledExecutorService scheduler = null;

    @Override
    public void run() {
        System.out.println("scheduletask is called");
        List<Car> carList = new ArrayList<>();
               carList = carService.findAll();
        if (carList != null) {
            for (Car car : carList) {
                System.out.println(car);
            }
        }
    }

我怀疑持久性上下文在调用时没有正确加载。

我遵循了以下问题使用计时器在JSF托管bean中为计划任务生成线程

调度作业上的scheduledExecutorService,timerService和无状态EJB

Answer 1

正如您所链接的第一个问题的答案中清楚地揭示的那样，只需将@schedule使用到一个带有@startup注释的@singletonSessionBean，以确保它在服务器启动或部署应用程序时运行。

正如您正确提到的，EntityManager和PersistenceContext不能注入到非容器管理的类中（而Singleton SessionBean是一个托管类）。

链接答案：

使用计时器在JSF托管bean中为计划任务生成线程