Examples of com.sun.sgs.kernel.schedule.SchedulerQueue.addTask()

Class com.sun.sgs.kernel.schedule.SchedulerQueue

Examples of com.sun.sgs.kernel.schedule.SchedulerQueue.addTask()

com.sun.sgs.kernel.schedule.SchedulerQueue.addTask()
Adds a task to the scheduler. This task is executed only once, but may be executed immediately or in the future.
Note that if this is a recurring task, then a call to its {@code getRecurringTaskHandle} method must return a handle providedby a call to this implementation's {@code createRecurringTaskHandle}method. Note also that it is up to the caller to re-schedule this task for each recurrence, and that each such call must provide a unique instance of {@code ScheduledTask}. @param task the {@code ScheduledTask} to add @throws TaskRejectedException if the task cannot be added

        assertNotNull(queue.getNextTask(false));
        assertNotNull(queue.getNextTask(false));
        assertNotNull(queue.getNextTask(false));
        assertNull(queue.getNextTask(false));


        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());

View Full Code Here

        assertNotNull(queue.getNextTask(false));
        assertNotNull(queue.getNextTask(false));
        assertNull(queue.getNextTask(false));


        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        LinkedList<ScheduledTask> tasks = new LinkedList<ScheduledTask>();

View Full Code Here

        assertNotNull(queue.getNextTask(false));
        assertNull(queue.getNextTask(false));


        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        LinkedList<ScheduledTask> tasks = new LinkedList<ScheduledTask>();
        assertEquals(6, queue.getNextTasks(tasks, 10));

View Full Code Here

        assertNull(queue.getNextTask(false));


        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        LinkedList<ScheduledTask> tasks = new LinkedList<ScheduledTask>();
        assertEquals(6, queue.getNextTasks(tasks, 10));
    }

View Full Code Here


        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        LinkedList<ScheduledTask> tasks = new LinkedList<ScheduledTask>();
        assertEquals(6, queue.getNextTasks(tasks, 10));
    }

View Full Code Here

        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        LinkedList<ScheduledTask> tasks = new LinkedList<ScheduledTask>();
        assertEquals(6, queue.getNextTasks(tasks, 10));
    }


    @Test (timeout=300)

View Full Code Here

    }


    @Test public void addAndConsumeTaskDelayed() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        ScheduledTask task = new ScheduledTaskImpl(100);
        queue.addTask(task);
        assertNull(queue.getNextTask(false));
        Thread.sleep(200);
        assertEquals(task, queue.getNextTask(false));
    }

View Full Code Here

    }


    @Test (timeout=200)
        public void addAndConsumeTaskDelayedWaiting() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        queue.addTask(new ScheduledTaskImpl(100));
        queue.getNextTask(true);
    }


    @Test public void addAndConsumeTasksDelayed() throws Exception {
        SchedulerQueue queue = getQueueInstance();

View Full Code Here

        queue.getNextTask(true);
    }


    @Test public void addAndConsumeTasksDelayed() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(120));
        queue.addTask(new ScheduledTaskImpl(110));
        Thread.sleep(200);
        assertNotNull(queue.getNextTask(false));

View Full Code Here

    }


    @Test public void addAndConsumeTasksDelayed() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(120));
        queue.addTask(new ScheduledTaskImpl(110));
        Thread.sleep(200);
        assertNotNull(queue.getNextTask(false));
        assertNotNull(queue.getNextTask(false));

View Full Code Here

0 1 2 3

TOP

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.