ejb 3.1中的计时器服务-计划呼叫超时问题

Question

我用@ Singleton，@ Schedule和@Timeout注释创建了一个简单的示例，以尝试它们是否可以解决我的问题。

场景是这样的：EJB每5秒调用一次“检查”功能，并且如果满足某些条件，EJB将创建单个动作计时器，该计时器将以异步方式调用一些长时间运行的进程。（这是某种队列实现类型的东西）。然后它继续检查，但是尽管运行了很长时间，但不会启动另一个过程。

下面是我想出的代码，但是该解决方案不起作用，因为看起来我正在进行的异步调用实际上阻止了@Schedule方法。

@Singleton
@Startup
public class GenerationQueue {

    private Logger logger = Logger.getLogger(GenerationQueue.class.getName());

    private List<String> queue = new ArrayList<String>();

    private boolean available = true;

    @Resource
    TimerService timerService;

    @Schedule(persistent=true, minute="*", second="*/5", hour="*")
    public void checkQueueState() {

        logger.log(Level.INFO,"Queue state check: "+available+" size: "+queue.size()+", "+new Date());

        if (available) {

            timerService.createSingleActionTimer(new Date(), new TimerConfig(null, false));
        }

    }

    @Timeout
    private void generateReport(Timer timer) {

        logger.info("!!--timeout invoked here "+new Date());

        available = false;

        try {

            Thread.sleep(1000*60*2); // something that lasts for a bit

        } catch (Exception e) {}

        available = true;

        logger.info("New report generation complete");

    }

我在这里缺少什么，还是应该尝试其他方法？任何想法最欢迎:)

使用Glassfish 3.0.1最新版本进行测试-忘了提及

Answer 1

单例的默认@ConcurrencyManagement为ConcurrencyManagementType.CONTAINER，默认@Lock为LockType.WRITE。基本上，这意味着每个方法（包括generateReports）都被有效地标记为synced关键字，这意味着在generateReport运行时，checkQueueState将被阻止。

考虑使用ConcurrencyManagement（ConcurrencyManagementType.BEAN）或@Lock（LockType.READ）。如果上述建议均无济于事，我怀疑您已找到Glassfish的错误。

顺便说一句，您可能需要persistent =
false，因为即使您的服务器处于脱机状态，您也不必保证checkQueueState方法每5秒触发一次。换句话说，当您使服务器重新联机时，您可能不需要容器触发“追赶”。