9

我正在使用 Timer 和 TimerTask 长轮询聊天应用程序的新消息。我想研究两种“稍微”不同的可能性：

1：定时器声明为局部变量

public List<MessageBean> getLastMessages(...) {
    [...]
    Timer timer = new Timer(true); //**Timer declared as local variable**
    while (someCondiction) {
        MessagesTimerTask returnMessagesTask = new MessagesTimerTask([...]);
        timer.schedule(returnMessagesTask, 6000);
        synchronized (listMessageBean) {
            listMessageBean.wait();
            //notify is called in the MessagesTimerTask which extends TimerTask
        }
    }
}

*问题：每次调用该方法时，我都可以看到创建了一个新线程，[Timer-1]、[Timer-2] 等。在 Eclipse 调试窗口中，即使在getLastMessages之后，它们似乎都在运行(..)完成运行并向客户端返回一个值。如果计时器实际上使用线程，这可能会导致一个巨大的问题，并且在少数事务之后，服务器最终将消耗所有机器资源。

2：定时器声明为本地字段

private final Timer timer = new Timer(true); //**Timer declared as local field**

public List<MessageBean> getLastMessages(...) {
    [...]
    while (someCondiction) {
        MessagesTimerTask returnMessagesTask = new MessagesTimerTask([...]);
        timer.schedule(returnMessagesTask, 6000);
        synchronized (listMessageBean) {
            listMessageBean.wait();
            //notify is called in the MessagesTimerTask which extends TimerTask
        }
    }
}

*问题：每次调用该方法时，都使用同一个线程[Thread-1]，但我不确定我是否连续两次调用，后者将取消/覆盖前者（该类是@Autowired by spring ) ?

有什么建议么 ？谢谢你。

4

1 回答 1

8

以下是该方法的源代码schedule：

190       public void schedule(TimerTask task, long delay) {
191           if (delay < 0)
192               throw new IllegalArgumentException("Negative delay.");
193           sched(task, System.currentTimeMillis()+delay, 0);
194       }

和sched方法：

386       private void sched(TimerTask task, long time, long period) {
387           if (time < 0)
388               throw new IllegalArgumentException("Illegal execution time.");
389   
390           // Constrain value of period sufficiently to prevent numeric
391           // overflow while still being effectively infinitely large.
392           if (Math.abs(period) > (Long.MAX_VALUE >> 1))
393               period >>= 1;
394   
395           synchronized(queue) {
396               if (!thread.newTasksMayBeScheduled)
397                   throw new IllegalStateException("Timer already cancelled.");
398   
399               synchronized(task.lock) {
400                   if (task.state != TimerTask.VIRGIN)
401                       throw new IllegalStateException(
402                           "Task already scheduled or cancelled");
403                   task.nextExecutionTime = time;
404                   task.period = period;
405                   task.state = TimerTask.SCHEDULED;
406               }
407   
408               queue.add(task);
409               if (queue.getMin() == task)
410                   queue.notify();
411           }
412       }

从这里你可以清楚地看到一个队列被用来在内部存储任务，这意味着后面的任务不会覆盖前面的任务。如果您还检查mainLoop文件中的方法，您可以看到它从队列中按计划时间一一排序并执行它们。

所以在同一个Timer对象上安排多个任务应该不是问题。

作为旁注，请考虑从 Java 1.5 开始替换Timer为可用。ScheduledThreadPoolExecutor

于 2012-08-18T05:42:20.083 回答