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

    @Test public void addTasksDelayed() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        ScheduledTask delayedTask = new ScheduledTaskImpl(testTask, 100);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
    }

View Full Code Here

        SchedulerQueue queue = getQueueInstance();
        ScheduledTask delayedTask = new ScheduledTaskImpl(testTask, 100);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
    }


    @Test (expected=NullPointerException.class)

View Full Code Here

        ScheduledTask delayedTask = new ScheduledTaskImpl(testTask, 100);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
    }


    @Test (expected=NullPointerException.class)
        public void addTaskNull() throws Exception {

View Full Code Here

        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
        queue.addTask(delayedTask);
    }


    @Test (expected=NullPointerException.class)
        public void addTaskNull() throws Exception {
        SchedulerQueue queue = getQueueInstance();

View Full Code Here

    }


    @Test (expected=NullPointerException.class)
        public void addTaskNull() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        queue.addTask(null);
    }


    /**
     * Recurring task addition tests.
     */

View Full Code Here

     */


    @Test public void addAndConsumeTask() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        ScheduledTask task = new ScheduledTaskImpl();
        queue.addTask(task);
        assertEquals(task, queue.getNextTask(false));
    }


    @Test (timeout=100)
        public void addAndConsumeTaskWaiting() throws Exception {

View Full Code Here

    }


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


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

View Full Code Here

        queue.getNextTask(true);
    }


    @Test public void addAndConsumeTasks() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        assertNotNull(queue.getNextTask(false));
        assertNotNull(queue.getNextTask(false));
        assertNotNull(queue.getNextTask(false));

View Full Code Here

    }


    @Test public void addAndConsumeTasks() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        assertNotNull(queue.getNextTask(false));
        assertNotNull(queue.getNextTask(false));
        assertNotNull(queue.getNextTask(false));
        assertNull(queue.getNextTask(false));

View Full Code Here


    @Test public void addAndConsumeTasks() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        queue.addTask(new ScheduledTaskImpl());
        assertNotNull(queue.getNextTask(false));
        assertNotNull(queue.getNextTask(false));
        assertNotNull(queue.getNextTask(false));
        assertNull(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.