0

タスクをスケジュールするクラスを開発しています。そのタスクに2分以上かかった場合は、タスクに2分以上かかったため、タスクが強制的に終了したこと、およびタスクが2分以内に完了した場合にメッセージを表示します。またはその前に、タスクが2分前に完了したというメッセージを表示します。ここでの課題は、ダミーのタスクが必要なことです。最初にループを実行してテストします。その方法を教えてください。以下は、私が持っているコードです。これまでに試しました。

import java.util.Timer;
import java.util.TimerTask;

public class Reminder {
    Timer timer;

    public Reminder(int seconds) {
        timer = new Timer();
        timer.schedule(new RemindTask(), seconds*1000);
   }

    class RemindTask extends TimerTask { // Nested Class
        public void run() {
             //hOW TO SET THE any kind of task which takes more than 5 minutes any loop or any sort of thing
        //   If elapsed time is > 50 minutes, something is not right
            System.out.format("Time's up since it takes more than 5 minutes....!%n");
            timer.cancel(); //Terminate the timer thread
        }
    }

    public static void main(String args[]) {
        new Reminder(5);
        System.out.format("Task scheduled.%n");

    }
}
4

1 に答える 1

1

これで始められます：

public abstract class LimitedTask {
    private final long timeOut;
    private final Timer timer;
    private final AtomicBoolean flag;

    protected LimitedTask(long timeOut) {
        this.timeOut = timeOut;
        this.timer = new Timer("Limiter",true);
        this.flag = new AtomicBoolean(false);
    }

    public void execute(){

       //---worker--
       final Thread runner = new Thread(new Runnable() {
           @Override
           public void run() {
               try{
                   doTaskWork();
               }catch (Exception e){
                   e.printStackTrace();
               }finally {
                   if(flag.compareAndSet(false,true)){
                       timer.cancel();
                       onFinish(false);
                   }
               }
           }
       },"Runner");

       runner.setDaemon(true);
       runner.start();

       //--timer--
       this.timer.schedule(new TimerTask() {
           @Override
           public void run() {

               runner.interrupt();

               if(flag.compareAndSet(false,true)){
                   onFinish(true);
               }
           }
       },this.timeOut);
    }

    public abstract void onFinish(boolean timedOut);

    public abstract void doTaskWork() throws Exception;

}

テストの実装:

public class TestTask extends LimitedTask {
    public TestTask() {
        super(10000);
    }

    @Override
    public void onFinish(boolean timedOut) {
        System.out.println(timedOut ? "Task timed out" : "Task completed");
    }

    @Override
    public void doTaskWork() throws Exception {
        for (int i = 0; i <100 ; i++){
            Thread.sleep(1000);
        }
    }
}

走る：

TestTask t = new TestTask();
t.execute();
于 2012-12-22T08:03:55.880 に答える