Package java.util

Examples of java.util.TimerTask

79
80
81
82
83
84
85
86
87
88
89
    }
  }

  private void startMaintenanceTimer(int period) {
    maintenanceTimer = new Timer(true);
    maintenanceTimer.schedule(new TimerTask() {
      public void run() {
        if (maintenanceScheduled) {
          gc();
          // need to lock for consistent backup
          lock.readLock().lock();
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
  private static Runnable runnable;

  public static void start() {
    stop();
    timer = new Timer();
    timer.schedule(new TimerTask() {
      public void run() {
        try {
          String newSource = Registry
              .getParameter(Names.JEASE_TIMER_TASK);
          if (Validations.isNotEmpty(newSource)) {
View Full Code Here
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
          sessionTemporaryFolder.deleteOnExit();
        }
       
        // Launch a timer that updates modification date of the temporary folder each minute
        final long updateDelay = 60000;
        new Timer(true).schedule(new TimerTask() {
            @Override
            public void run() {
              // Ensure modification date is always growing in case system time was adjusted
              sessionTemporaryFolder.setLastModified(Math.max(System.currentTimeMillis(),
                  sessionTemporaryFolder.lastModified() + updateDelay));
            }
          }, updateDelay, updateDelay);
       
        if (siblingTemporaryFolders != null
            && siblingTemporaryFolders.length > 0) {
          // Launch a timer that will delete in 10 min temporary folders older than a week
          final long deleteDelay = 10 * 60000;
          final long age = 7 * 24 * 3600000;
          new Timer(true).schedule(new TimerTask() {
              @Override
              public void run() {
                long now = System.currentTimeMillis();
                for (File siblingTemporaryFolder : siblingTemporaryFolders) {
                  if (siblingTemporaryFolder.exists()
View Full Code Here
237
238
239
240
241
242
243
244
245
246
247
      this.timer = null;
    }
    int autoSaveDelayForRecovery = this.application.getUserPreferences().getAutoSaveDelayForRecovery();
    if (autoSaveDelayForRecovery > 0) {
      this.timer = new Timer("autoSaveTimer", true);
      TimerTask task = new TimerTask() {
        @Override
        public void run() {
          if (System.currentTimeMillis() - lastAutoSaveTime > MINIMUM_DELAY_BETWEEN_AUTO_SAVE_OPERATIONS) {
            cloneAndSaveHomes();
          }
View Full Code Here
179
180
181
182
183
184
185
186
187
188
189
        public void onRequest(final IHttpExchange exchange) throws IOException, BadMessageException {
            receivedRequests.incrementAndGet();
           
            int delay = exchange.getRequest().getIntParameter("delay", 0);
                   
            TimerTask task = new TimerTask() {
                @Override
                public void run() {
                    try {
                        exchange.send(new HttpResponse(200, "text/plain", "OK"));
                    } catch (IOException ioe) {
View Full Code Here
226
227
228
229
230
231
232
233
234
235
236
      }
    }

   
    protected final void sendLater(int delayMillis, final IHttpRequest request) {
      TimerTask task = new TimerTask() {
        @Override
        public void run() {
          sendNow(request);
        }
      };
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
                // sending the response header
                final BodyDataSink sink = exchange.send(new HttpResponseHeader(200, "text/event-stream"));

               
                TimerTask tt = new TimerTask() {

                    private int id = Integer.parseInt(exchange.getRequest().getHeader("Last-Event-Id", "0"));
                   
                    public void run() {
                        try {
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
                // sending the response header
                final BodyDataSink sink = exchange.send(new HttpResponseHeader(200, "text/event-stream"));

               
                TimerTask tt = new TimerTask() {

                    private int id = Integer.parseInt(exchange.getRequest().getHeader("Last-Event-Id", "0"));
                   
                    public void run() {
                        try {
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
                final String idString = exchange.getRequest().getHeader("Last-Event-Id", "0");

                // sending the response header
                final BodyDataSink sink = exchange.send(new HttpResponseHeader(200, "text/event-stream"));

                TimerTask tt = new TimerTask() {

                    private int id = Integer.parseInt(idString);
                   
                    public void run() {
                        try {
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
                final String idString = exchange.getRequest().getHeader("Last-Event-Id", "0");

                // sending the response header
                final BodyDataSink sink = exchange.send(new HttpResponseHeader(200, "text/event-stream"));

                TimerTask tt = new TimerTask() {

                    private int id = Integer.parseInt(idString);
                   
                    public void run() {
                        try {
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.