4

我想ExecutorService在 JAVA 中使用每 5 分钟安排一次插入数据库。这是我要执行的任务:

    MyClass{
     a counter that count a handled data received from a Thread
     I receive usually 300 data line/second
     Apply a treatment on these data and keep the results in the memory

    every five minutes {
               update the database with the counters saved in memory*
      }
}

基本上,每次他从后台运行的线程中获取数据时,它都会调用该任务。因为我有超过 300 个数据/秒,所以不可能以这种方式使用它。

所以我想要做什么来处理收到的任务并在内存中保留一个计数器并每 5 分钟更新一次数据库。

我的问题是,是否可以使用这些 java 函数ScheduledExecutorService来执行此操作,我们该怎么做(我不想在任务上阻止我的 JAVA 应用程序 5 分钟,我希望该应用程序正常运行但不执行任务每次,如果您能向我展示这些功能的用法示例,我将不胜感激?

4

1 回答 1

8
ScheduledExecutorService service = Executors.newScheduledThreadPool(1);
service.scheduleAtFixedRate(command, 5, 5, TimeUnit.MINUTES);

在哪里command

Runnable command = new Runnable() {
   public void run() {
      // update database
   }
}
于 2013-10-21T08:54:56.323 回答