我在我的网络中设置了 2 个服务.xml并为每个服务创建一个 shedule 服务,如下所示:
public class MyScheduler implements ServletContextListener {
private ScheduledExecutorService scheduledExecutorService = null;
@Override
public void contextInitialized(ServletContextEvent sce) {
if ((scheduledExecutorService == null) || (!scheduledExecutorService.isTerminated())) {
scheduledExecutorService = Executors.newSingleThreadScheduledExecutor();
scheduledExecutorService.scheduleAtFixedRate(new MyScheduledTimer(), 0, 15, TimeUnit.DAYS);
}
}
@Override
public void contextDestroyed(ServletContextEvent sce) {
try {
scheduledExecutorService.shutdown();
} catch (Exception ex) {
}
}
}
class MyScheduledTimer extends TimerTask {
{
try {
MyEjb ejbObject = (InterfaceEjb) new InitialContext().lookup("java:global/project/MyEjb");
} catch (NamingException ex) {
Logger.getLogger(MyScheduler.class.getName()).log(Level.SEVERE, null, ex);
} catch (Exception ex) {
Logger.getLogger(MyScheduler.class.getName()).log(Level.SEVERE, null, ex);
}
}
@Override
public void run() {
//my code to run with ejbObject...
}
}
我想运行第一个服务来启动我的应用程序,等待此服务完成,然后运行第二个服务。有可能吗?
如果你想使用更具体的东西 - 你可以使用CountDownLatch。创造
CountDownLatch latch = new CoundownLatch(1);
第一次服务将在完成工作后呼叫countDown()
。
//service1
public void run(){
doSmthng();
latch.countDown();
}
第二个服务将等到闩锁计数器不等于 0。
//service2
public void run(){
latch.await();
doSmthngElse();
}