Package java.util

Examples of java.util.TimerTask

2989
2990
2991
2992
2993
2994
2995
2996
2997
2998
2999
        }
        if (cleanStatusTask != null) {
            cleanStatusTask.cancel();
        }
        status.setText(message);
        cleanStatusTask = new TimerTask() {
            public void run() {
                status.setText("");
                cleanStatusTask.cancel();
                cleanStatusTask = null;
            }
View Full Code Here
288
289
290
291
292
293
294
295
296
297
298
      e.printStackTrace();
      return;
    }
    _network_manager = (InternalNetworkManager) NetworkManagerSingleton.getInstance();
    need_more_peers_timer = new Timer( "Need more peers timer", true );
    need_more_peers_timer.scheduleAtFixedRate( new TimerTask() {
      @Override
      public void run() {
        Set<FileHash> file_hashes = session_list.keySet();
        List<FileHash> file_hashes_needed_help = new ArrayList<FileHash>();
        for(FileHash file_hash : file_hashes) {
View Full Code Here
431
432
433
434
435
436
437
438
439
440
441
        synchronized (this) {
            _accumulator += zoomIncrement;
            if (_zoomAccumulator != null)
                return;
            _zoomAccumulator = new Timer();
            _zoomAccumulator.schedule(new TimerTask() {
                public void run() {
                    int accuCopy;
                    synchronized (ViewTransform.this) {
                        accuCopy = _accumulator;
                        _accumulator = 0;
View Full Code Here
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
    } catch (JMuleManagerException e) {
      e.printStackTrace();
      return ;
    }
    remove_temp_banned_peers_timer = new Timer( "Remove temp banned peers timer", true );
    remove_temp_banned_peers_timer.scheduleAtFixedRate(new TimerTask() {
      @Override
      public void run() {
        for(TemporaryBannedIP banned_ip : temporary_banned_peers)
          if( ( System.currentTimeMillis() - banned_ip.getWhenBanned() ) >= banned_ip.getHowLong() )
            temporary_banned_peers.remove( banned_ip );
      }
    }, (long)1, REMOVE_TEMP_BANNED_PEERS_INTERVAL);
   
    remove_temp_banned_servers_timer = new Timer( "Remove temp banned servers timer", true);
    remove_temp_banned_servers_timer.scheduleAtFixedRate(new TimerTask() {
      @Override
      public void run() {
        for(TemporaryBannedIP banned_ip : temporary_banned_servers)
          if( ( System.currentTimeMillis() - banned_ip.getWhenBanned() ) >= banned_ip.getHowLong() )
            temporary_banned_servers.remove( banned_ip );
View Full Code Here
309
310
311
312
313
314
315
316
317
318
319
        if (null == workQueue) {
            LOG.fine("Starting retransmission queue");
            workQueue = queue;
            // workQueue.schedule(getResendInitiator(), baseRetransmissionInterval);
           
            TimerTask task = new TimerTask() {
                public void run() {
                    getResendInitiator().run();
                }
            };
            timer = new Timer();
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
  protected abstract void throwInterruptedException()
    throws StoreException;

  private void startTimer(long timeLimit) {
    TimerTask tt = new TimerTask() {

      @Override
      public void run() {
        interrupt();
      }
View Full Code Here
849
850
851
852
853
854
855
856
857
858
859
        if (syncTimerTask != null) {
          logger.error("syncTimerTask is not null");
        }

        syncTimerTask = new TimerTask() {

          @Override
          public void run() {
            try {
              // Acquire read lock to guarantee that the statement list
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
  }

  // ÿ�����ϰ�ҹʱ���Զ�����
  private void manager() {
    Timer timer = new Timer();
    TimerTask tt2 = new TimerTask() {
      public void run() {
        loadNewWords();
      }
    };
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
   
   
   
    
    public HttpCache() {
        timerTask = new TimerTask() {
            public void run() {
                cache.periodicChecks();
            }
        };
               
View Full Code Here
147
148
149
150
151
152
153
154
155
156
157
   * Starts to update the values with the previously set period. Default is 1 second.
   */
  public void start() {
    if (isRunning()) return;
    timer = new Timer(true); // do not block the application on exit
    timer.scheduleAtFixedRate(new TimerTask() {
      public void run() {
        try {
          step();
        } catch (DataException e) {
          if (autoStop && (e instanceof NoSuchIndex)) {
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.