问题：

计时器任务Java意外行为

陈浩

2023-03-14

我的计时器任务没有正常工作。我计划每3秒钟重复一次特定的任务，但这并没有发生。

根据Java文件：

计划（TimerTask任务、长延迟、长周期）。将指定的任务安排为重复的固定延迟执行，从指定的延迟后开始。随后的执行大约按规定的时间间隔定期进行。

public class Tester {

    public static void main(String[] args) {    
        log.info("Schedule task");
        Timer time = new Timer();

        TesterClient tc = new TesterClient();
        time.schedule(tc, 0, 3000);
    }
}


public class TesterClient extends TimerTask {
    public void init() {
        System.out.println("New Task!!!!");
    }
    @Override
    public void run() {
        init();
    }
}

但我只有一个“新任务！！！！”控制台打印

我是不是遗漏了什么？

谢谢

更新：

我将尝试在这里粘贴每一段相关的代码，从上到下执行。

开始：

public class Tester {

    public static Logger log = Logger.getLogger("com.orderlysoftware.orderlycalls.manager.ManagerClient");
    public static Timer time = new Timer();

    public static void main(String[] args) {            
        log.info("Creating service");
        Service.serviceInit();  

        log.info("Initializing TesterClient for scheduled task");
        TesterClient tc = new TesterClient();
        time.schedule(tc, 0, 3000);
    }
    public static ManagerSettings managerSettings() {
        ManagerSettings managerSettings = new ManagerSettings();
        managerSettings.setName("managerClient");
        managerSettings.setHost("77.237.251.152");
        managerSettings.setPort(5038);
        managerSettings.setUsername("orderlystats");
        managerSettings.setPassword("orderlystats");

        return managerSettings;
    }   
}

Service class method:

static ExecutorService executorService; 
    {
        serviceInit();
    }

    //public static ClassLoader loader;

    public static void serviceInit(){
        if(executorService!=null) {
            return;
        }
        executorService= Executors.newCachedThreadPool();
        try {
            ThreadPoolExecutor tpe=(ThreadPoolExecutor)executorService;
            tpe.setMaximumPoolSize(100000);
        } catch (Exception ex) {
            System.out.println(ex);
        }
    }

package com.orderlysoftware.testing;

import java.io.IOException;
import java.util.TimerTask;
import java.util.concurrent.ExecutorService;
import java.util.logging.Logger;

import com.orderlysoftware.orderlycalls.OrderlyCalls;
import com.orderlysoftware.orderlycalls.asterisk.manager.ManagerClient;
import com.orderlysoftware.orderlycalls.asterisk.manager.action.ManagerResponse;
import com.orderlysoftware.orderlycalls.asterisk.manager.event.ManagerEvent;
import com.orderlysoftware.orderlycalls.asterisk.manager.event.ManagerEventListener;
import com.orderlysoftware.orderlycalls.base.Service;

public class TesterClient extends TimerTask {

    public static Logger log = Logger.getLogger("com.orderlysoftware.orderlycalls.manager.ManagerClient");
    public static ExecutorService es = Service.getExecutorService();

    public ManagerClient mc;

    public void init() {    
        log.info("run check method to see if Manager Client is running");
        boolean running = check();

        log.info("checker status is : " + running);
        while(running) {
            try {
                Thread.sleep(3000);
                startCall();
            } catch (InterruptedException e) {
                log.info("Sleep interrupted");
            }
        }   
    }
    public boolean check() {
        log.info("ManagerClient is: " + mc);
        if(mc == null) {
            log.info("Initialize service");
            mc = (ManagerClient)OrderlyCalls.createService(ManagerClient.class, Tester.managerSettings());
            log.info("Initialize ManagerClient");
            mc.init();
            log.info("Service created. ManagerClient initialized : "+ mc);
        }
        if(!mc.isConnected()) {
            log.info("ManagerClient is not connected");         
            return false;
        }
        log.info("Check if ManagerClient is connected AND running");
        if(mc.isConnected() && !mc.isRunning()) {
            log.info("Manager Client is connected but NOT running");
            return false;
        }
        if(mc.isConnected() && mc.isRunning()) {
            log.info("ManagerClient is connected and running");
            return true;
        }
        return false;
    }
    private void startCall() {
        log.info("Adding listener to the call");
        addListenerToCall(mc);

        int testID = 0;
        ManagerResponse response = null;
        try {
            response = mc.originate("Local/1001@main", "1001", "main", "1", null, null, 2500, "1002", "testID=" + (testID++), "1", true);
            log.info("Manager response is: " + response);
            if(response == null) {
                mc.shutdown();
                throw new IOException("Null response for originate.");              
            }
            if(!response.getValue("Response").equals("Success")) {
                mc.shutdown();
                throw new IOException("Originate returned " + response.getValue("Response") + ": " + response.getValue("Message"));
            }
        } catch (IOException e) {
            log.info("IO Exception" + e.toString());
        }
    }   
    public void addListenerToCall(ManagerClient mc) {       
        try {
            // Add event listener 
            log.info("Adding ManagerEventListener to ManagerClient: " + mc);
            mc.addManagerEventListener(new ManagerEventListener() {         
                @Override
                public void handleManagerEvent(ManagerEvent event) {
                    if("OriginateResponse".equals(event.getType())) {
                        handleOriginateResponse(event);
                    }
                }
            });
        } catch (IOException e) {
            log.info("IO Exception : " + e);
        }       
    }
    protected void handleOriginateResponse(ManagerEvent event) {
        try {
            // do something here 
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            log.info("sleep interupted" + e);
        }           
    }

    @Override
    public void run() {
        log.info("New Task!!!!!!!!!!");
        init(); 
    }   
}

共有2个答案

蔡默

2023-03-14

你的程序对我也很好。这个问题被转载了，在你的节目中有以下变化：

import java.util.*;
public class Tester {

    public static void main(String[] args) {
        System.out.println("Schedule task");
        Timer time = new Timer();

        TesterClient tc = new TesterClient();
        time.schedule(tc, 0, 3000);
    }
}


class TesterClient extends TimerTask {
    public void init() {
        System.out.println("New Task!!!!");
    }
    @Override
    public void run() {
        init();
        this.cancel(); //-------This causes hang in execution after printing once
    }
}

但是，不确定在程序中没有cancel（）的情况下，是什么导致了这种情况。

凌俊名

2023-03-14

这对我来说是可行的，但我怀疑问题在于你让计时器回收垃圾：

在对计时器对象的最后一个实时引用消失并且所有未完成的任务都已完成执行后，计时器的任务执行线程将正常终止（并成为垃圾收集的对象）。但是，这可能需要任意长的时间。

正如评论中指出的，我认为“未完成的任务”是指“已经开始的任务”，而不仅仅是“将要安排的任务”。然而，文件不清楚，我可能弄错了。

如果您阻止垃圾收集（例如，通过在静态变量中保留对计时器的引用），那么我认为您将看到它一直在运行。。。

类似资料：

Java计时器任务首次运行

我有一个Java的计时器任务来生成每日报告。当我通过linux终端调用Java类（调度定时器任务），而不是在给定时间调度第一次运行时，它会在命令执行后立即运行。有人能建议为什么会这样吗... 我使用的计划它。忘了补充一下，我使用的是java 1.5，这里是def方法代码片段：
计时器和计时器任务-如何从计时器任务运行中重新安排计时器

基本上，我想做的是制作一个计时器，在x秒后运行一个特定的TimerTask，但是TimerTask可以重新安排计时器在y秒后执行任务。下面是一个示例，它在我试图在TimerTask run中调度此任务的行上给出了一个错误“线程中的异常”Timer-0“java.lang.IllegalStateException:任务已调度或已取消”。
java中意外触发的计时器

我用固定速率启动计时器。当用户更改系统时间时，此时任务将连续执行。它没有考虑时段。如何管理。注：现在系统时间为当前时间。周期为30秒。现在用户将系统时间从当前时间改为10分钟后。当时计时器任务不考虑周期。在一秒钟内，它执行了20次任务。当我使用而不是任务工作正常。如果我将系统时间更改为10分钟过去的时间，从现在起任务不会执行。。。如何解决这个问题(
java计时器任务多线程

我使用Timer和TimerTask为聊天应用程序长轮询新消息。我想研究两种“稍微”不同的可能性： 1：计时器声明为局部变量 *问题：每次调用该方法时，我都会看到创建了一个新线程，[Timer-1]、[Timer-2]等等。。在Eclipse调试窗口中，即使在getLastMessages（..）之后，它们似乎都在运行完成运行并向客户端返回值。如果计时器实际使用线程，并且在几次事务之后，服务器最终
计划任务在java使用定时器

我已经使用java创建了特定于时区的计划任务事件。我的密码是贝娄。但是问题是当调用这个方法时，它会很快运行这个任务。我需要每天12点在亚洲/科伦坡时区运行这项工作。那要怎么做？
使用一个计时器处理多个计时器任务

但是我不能在一个计时器中处理不同的“计时器任务”。我试图将计时器任务对象添加到构造函数中，但是当我将新的计时器任务（RemindTask1）对象作为参数（内部类的实例）传递时，出现编译错误。以下是它如何处理一项任务：但是我完全被多个任务应该如何创建然后运行所困扰。但是这不起作用，我不知道出了什么问题。当我将新的RemindTask2（）作为参数传递时，我遇到了编译错误。

计时器任务Java意外行为

共有2个答案

相关问答

相关文章

相关阅读

相关工具

相关文档