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 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));
        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));
        assertNotNull(queue.getNextTask(false));
        assertNotNull(queue.getNextTask(false));

View Full Code Here

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


        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(120));
        queue.addTask(new ScheduledTaskImpl(110));
        queue.addTask(new ScheduledTaskImpl(150));
        LinkedList<ScheduledTask> tasks = new LinkedList<ScheduledTask>();

View Full Code Here

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


        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(120));
        queue.addTask(new ScheduledTaskImpl(110));
        queue.addTask(new ScheduledTaskImpl(150));
        LinkedList<ScheduledTask> tasks = new LinkedList<ScheduledTask>();
        assertEquals(0, queue.getNextTasks(tasks, 5));

View Full Code Here

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


        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(120));
        queue.addTask(new ScheduledTaskImpl(110));
        queue.addTask(new ScheduledTaskImpl(150));
        LinkedList<ScheduledTask> tasks = new LinkedList<ScheduledTask>();
        assertEquals(0, queue.getNextTasks(tasks, 5));
        Thread.sleep(200);

View Full Code Here

        assertNull(queue.getNextTask(false));


        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(120));
        queue.addTask(new ScheduledTaskImpl(110));
        queue.addTask(new ScheduledTaskImpl(150));
        LinkedList<ScheduledTask> tasks = new LinkedList<ScheduledTask>();
        assertEquals(0, queue.getNextTasks(tasks, 5));
        Thread.sleep(200);
        assertEquals(3, queue.getNextTasks(tasks, 3));

View Full Code Here


        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(100));
        queue.addTask(new ScheduledTaskImpl(120));
        queue.addTask(new ScheduledTaskImpl(110));
        queue.addTask(new ScheduledTaskImpl(150));
        LinkedList<ScheduledTask> tasks = new LinkedList<ScheduledTask>();
        assertEquals(0, queue.getNextTasks(tasks, 5));
        Thread.sleep(200);
        assertEquals(3, queue.getNextTasks(tasks, 3));
        assertEquals(2, queue.getNextTasks(tasks, 3));

View Full Code Here


    @Test (timeout=1000)
        public void addAndConsumeManyTasks() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        for (int i = 0; i < 537; i++)
            queue.addTask(new ScheduledTaskImpl(50));
        for (int i = 0; i < 679; i++)
            queue.addTask(new ScheduledTaskImpl());
        int count = 0;
        while (queue.getNextTask(false) != null)
            count++;

View Full Code Here

        public void addAndConsumeManyTasks() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        for (int i = 0; i < 537; i++)
            queue.addTask(new ScheduledTaskImpl(50));
        for (int i = 0; i < 679; i++)
            queue.addTask(new ScheduledTaskImpl());
        int count = 0;
        while (queue.getNextTask(false) != null)
            count++;
        Thread.sleep(100);
        while (queue.getNextTask(false) != null)

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.