Package org.waveprotocol.wave.client.scheduler.Scheduler

Examples of org.waveprotocol.wave.client.scheduler.Scheduler.IncrementalTask

322
323
324
325
326
327
328
329
330
331
332
    assertFalse(task1.wasExecuted);
    assertEmpty(true);
  }

  public void testCancellingAnIncrementalTaskDuringExecutionIgnoresContinueValue() {
    IncrementalTask mock = new IncrementalTask() {
      boolean cancelled;
      @Override
      public boolean execute() {
        if (cancelled) {
          fail("Cancelled task was not removed from scheduler");
View Full Code Here
208
209
210
211
212
213
214
215
216
217
218
  }

  /** Tests that multiple processes can be run at the same time. */
  public void testMultipleProcessesAtSameTime() {
    final int time = 100;
    final IncrementalTask anotherTask = mock(IncrementalTask.class, "anotherTask");
    timer.scheduleRepeating(repeating, 0, time);
    timer.scheduleRepeating(anotherTask, time, time);

    checking(new Expectations() {{
      one(repeating).execute();
View Full Code Here
228
229
230
231
232
233
234
235
236
237
238
    cancel(process);
    tasks.add(new TimedTask(currentTime + minimumTime, process, interval));
  }

  private boolean findOrCancel(Schedulable job, boolean remove) {
    IncrementalTask incrementalTask;
    if (job instanceof IncrementalTask) {
      incrementalTask = (IncrementalTask) job;
    } else if (job instanceof Task) {
      incrementalTask = new TaskAsIncrementalTask((Task) job);
    } else {
View Full Code Here
289
290
291
292
293
294
295
296
297
298
299
300
   */
  public void tick(int millisToAdvance) {
    currentTime += millisToAdvance;
    while (!tasks.isEmpty() && tasks.peek().getTime() <= currentTime) {
      TimedTask timedTask = tasks.poll();
      IncrementalTask task = timedTask.getTask();
      boolean doReschedule = task.execute();
      if (doReschedule) {
        // Note: If the next execution is at or before currentTime, the task
        // will be re-executed before this tick() call returns.
        tasks.add(timedTask.nextExecution());
      }
View Full Code Here
225
226
227
228
229
230
231
232
233
234
235
    cancel(process);
    tasks.add(new TimedTask(currentTime + minimumTime, process, interval));
  }

  private boolean findOrCancel(Schedulable job, boolean remove) {
    IncrementalTask incrementalTask;
    if (job instanceof IncrementalTask) {
      incrementalTask = (IncrementalTask) job;
    } else if (job instanceof Task) {
      incrementalTask = new TaskAsIncrementalTask((Task) job);
    } else {
View Full Code Here
286
287
288
289
290
291
292
293
294
295
296
297
   */
  public void tick(int millisToAdvance) {
    currentTime += millisToAdvance;
    while (!tasks.isEmpty() && tasks.peek().getTime() <= currentTime) {
      TimedTask timedTask = tasks.poll();
      IncrementalTask task = timedTask.getTask();
      boolean doReschedule = task.execute();
      if (doReschedule) {
        // Note: If the next execution is at or before currentTime, the task
        // will be re-executed before this tick() call returns.
        tasks.add(timedTask.nextExecution());
      }
View Full Code Here
TOP

Related Classes of org.waveprotocol.wave.client.scheduler.Scheduler.IncrementalTask

  • org.waveprotocol.wave.client.scheduler.BrowserBackedSchedulerGwtTest
  • org.waveprotocol.wave.client.scheduler.testing.FakeTimerService
  • org.waveprotocol.wave.client.scheduler.testing.FakeTimerServiceTest
    • 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.