Examples of java.util.Timer$Scheduler

java.util.Timer
The scheduler that executes all the tasks on a particular TaskQueue, reschedules any repeating tasks and that waits when no task has to be executed immediately. Stops running when canceled or when the parent Timer has been finalized and no more tasks have to be executed.

    } catch (JMuleManagerException e) {
      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>();

View Full Code Here

        }
        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;

View Full Code Here

      super.start();
    } 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() )

View Full Code Here

            TimerTask task = new TimerTask() {
                public void run() {
                    getResendInitiator().run();
                }
            };
            timer = new Timer();
            timer.schedule(task, getBaseRetransmissionInterval(), getBaseRetransmissionInterval());  
        }
    }

View Full Code Here

            destination = new RMDestination(this);
            destination.restore();
        }
        
        if (null == timer) {
            timer = new Timer();
        }
        
        if (!busLifeCycleListenerRegistered) {
            getBinding().getBus().getLifeCycleManager()
                .registerLifeCycleListener(new RMBusLifeCycleListener(getSource()));

View Full Code Here

         // if there is a timer and no change about the refreshperiod, let it do its job
        if (_refreshPeriodChanged || _timer == null){
            _refreshPeriodChanged = false;
            if (_timer!=null) 
                _timer.cancel();
            _timer = new Timer(true); // do not block the application on exit
            _timer.schedule(new SceneTimerTask(),0,_refreshPeriod);
        }
    }

View Full Code Here

      public void run() {
        interrupt();
      }
    };


    timer = new Timer("TimeLimitCursor", true);
    timer.schedule(tt, timeLimit);
  }

View Full Code Here

    else if (syncDelay > 0L) {
      synchronized (syncTimerSemaphore) {
        // Sync in syncDelay milliseconds
        if (syncTimer == null) {
          // Create the syncTimer on a deamon thread
          syncTimer = new Timer("MemoryStore synchronization", true);
        }


        if (syncTimerTask != null) {
          logger.error("syncTimerTask is not null");
        }

View Full Code Here

    }


  static public void main(String[] args) {
    Calendar c = Calendar.getInstance(); // contains current startup time
    //c.add(Calendar.SECOND, 30); // starting in 30 seconds
    Timer timer = new Timer();
    timer.schedule(new TestMetarEncoding(), c.getTime(), (long) 1000 * 120); // delay 2 min between runs
  }

View Full Code Here

    }
  }


  // ÿ�����ϰ�ҹʱ���Զ�����
  private void manager() {
    Timer timer = new Timer();
    TimerTask tt2 = new TimerTask() {
      public void run() {
        loadNewWords();
      }
    };


    Date date = Config.update_keys_time();
    timer.schedule(tt2, date, Config.update_keys_interval() * 60000);


  }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of java.util.Timer$Scheduler

aibo.AIBO

ar.com.AmberSoft.iEvenTask.events.BackgroundEventController

bg.smoc.model.manager.ContestManager

br.com.procempa.modus.ui.usuario.UsuarioTableModel

br.com.procempa.modus.ui.visita.VisitaAtivaView

br.com.procempa.modus.ui.visita.VisitaAtivaView$ClockCellRenderer

clockradio.ClockGUI

com.alibaba.otter.canal.parse.inbound.AbstractEventParser

com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser

com.alibaba.rocketmq.example.benchmark.Consumer

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.