Package java.util

Examples of java.util.TimerTask

182
183
184
185
186
187
188
189
190
191
    public void cancelTimerTasks(Collection ids) {
        for (Iterator iterator = ids.iterator(); iterator.hasNext();) {
            Long idLong = (Long) iterator.next();
            WorkInfo workInfo = getWorkInfo(idLong);
            if (workInfo != null) {
                TimerTask timerTask = workInfo.getExecutorFeedingTimerTask();
                timerTask.cancel();
            }
        }
    }
View Full Code Here
310
311
312
313
314
315
316
317
318
319
320
    */
    synchronized void scheduleTimeoutTask(long timeoutMillis) {
        // schedule a time out task if the timeout was specified
        if (timeoutMillis > 0) {
            // take care of the transaction timeout
            TimerTask cancelTask = new CancelXATransactionTask();
            TimerFactory timerFactory = Monitor.getMonitor().getTimerFactory();
            Timer timer = timerFactory.getCancellationTimer();
            timer.schedule(cancelTask, timeoutMillis);
        } else {
            timeoutTask = null;
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
      
       if(waitForIt) {
           log.info("Waiting for destroyed process {} to exit (timeout={} seconds)", processInfo, timeoutSeconds);
           final Thread mainThread = Thread.currentThread();
           final Timer t = new Timer(true);
           final TimerTask task = new TimerTask() {
                @Override
                public void run() {
                    mainThread.interrupt();
                }
           };
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
    modelWatcher.setModelHandler(modelHandler);

    // schedule a retry every thirty seconds in case we can't reset the
    // watch
    timer = new Timer();
    timer.scheduleAtFixedRate(new TimerTask() {
      @Override
      public void run() {
        modelWatcher.process(null);
      }
    }, 0, 3000);
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
          if (!curText.equals(lastText)) {
            if (timer != null) {
              timer.cancel();
            }
            timer = new Timer();
            timer.schedule(new TimerTask() {
              @Override
              public void run() {
                composite.getDisplay().syncExec(task);
              }
            }, timerDelay);
View Full Code Here
298
299
300
301
302
303
304
305
306
307
308
        
       if(mColorTimer != null)
         mColorTimer.cancel();
      
         //create the task for a timer tick
         TimerTask task = new TimerTask()
         {
             public void run()
             {
               initColors();
               repaint();
View Full Code Here
498
499
500
501
502
503
504
505
506
507
508
            timeoutTask = null;
        }

        if (deadLine > System.currentTimeMillis())
        {
            timeoutTask = new TimerTask()
            {
                @Override
                public void run()
                {
                    CoordinationImpl.this.timeout();
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
        return (TimerEndpoint) super.getEndpoint();
    }

    @Override
    protected void doStart() throws Exception {
        task = new TimerTask() {
            // counter
            private final AtomicLong counter = new AtomicLong();

            @Override
            public void run() {
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
        final AtomicBoolean hasTimedOut = new AtomicBoolean(false);
        Timer timer = null;
        try {
            if (timeoutMs < Long.MAX_VALUE) {
                timer = new Timer(true);
                timer.schedule(new TimerTask() {

                    @Override
                    public void run() {
                        hasTimedOut.set(true);
                    }
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
                    public void buttonClick(ClickEvent event) {
                        counter2.setValue(0);
                        if (task != null) {
                            task.cancel();
                        }
                        task = new TimerTask() {

                            @Override
                            public void run() {
                                access(new Runnable() {
                                    @Override
View Full Code Here
TOP

Related Classes of java.util.TimerTask

  • aibo.AIBO
  • com.alibaba.otter.canal.parse.inbound.AbstractEventParser
  • com.alibaba.rocketmq.example.benchmark.Producer
  • com.alibaba.rocketmq.remoting.netty.NettyRemotingClient
  • com.alibaba.rocketmq.remoting.netty.NettyRemotingServer
  • com.alibaba.rocketmq.store.schedule.ScheduleMessageService
  • com.alimama.mdrill.solr.hbaserealtime.realtime.RealTimeDirectoryThread
  • com.alimama.mdrill.solr.realtime.realtime.RealTimeDirectoryThread
  • com.arjuna.wst.messaging.engines.CoordinatorEngine
  • com.arjuna.wst11.messaging.engines.CoordinatorEngine
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.