任务是实现一个非常非常简化的计算“云”。云实例(“引擎”)应该定期向主管发送保持 Activity 消息(“命令”)。我已经使用以下任务实现了这一点:
public class KeepAlive implements Runnable {
Engine engine;
DatagramSocket sock;
public KeepAlive(Engine engine) {
this.engine = engine;
sock = new DatagramSocket();
}
public void run() {
DatagramSocket sock = null;
EngineArguments args = engine.getArgs();
KeepAliveCommand cmd = new KeepAliveCommand(…);
byte[] data = cmd.toString().getBytes("UTF-8");
DatagramPacket p = new DatagramPacket(data, data.length, InetAddress.getByName(args.getSchedulerHost()), args.getSchedulerPort());
sock.send(p);
}
}
计划使用 scheduleAtFixedRate() 执行。我正在使用 shutdownNow() 进行优雅(ish)关闭以避免必须保留对长时间运行的任务的显式引用。
是否有任何“干净”的方法来执行特定于任务的清理(关闭DatagramSocket
)?或者,在计划运行之间保留 DatagramSocket 实例是否有意义,或者我可以每次都创建一个新实例吗?
最佳答案
据我所知,您有两个选择:
- 跟踪“套接字池”中的套接字并使用该池的“发送”方法。 然后,在关闭执行器后,关闭池
- 扩展ScheduledThreadPoolExecutor,这可能有点困难。但是,API 很干净...请注意,您可以“装饰”任务,还有一个“终止”方法。
我喜欢“套接字池”的想法。然后,如何处理连接取决于池(即,如果您有持久连接或每个请求创建一个连接)
关于java - 使用 ScheduledExecutorService 时在哪里对计划任务执行最终清理,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/7985912/