Examples of com.sun.sgs.kernel.TaskQueue.addTask()

com.sun.sgs.kernel.TaskQueue.addTask()
Adds a task to this dependency queue. @param task the {@code KernelRunnable} to add @param owner the {@code Identity} that owns the task

            TaskQueue queue = taskQueues.get(queueOwner);
            if (queue==null) {
                queue = transactionScheduler.createTaskQueue();
                taskQueues.put(queueOwner, queue);
            }
            queue.addTask(task, identity);
        }
    }


    public void deleteTransactionQueue(Object queueOwner) {
        synchronized(taskQueues) {

View Full Code Here

  if (taskQueue == null) {
      taskQueue = taskScheduler.createTaskQueue();
      channelTaskQueues.put(channelRefId, taskQueue);
  }
  for (KernelRunnable task : taskList) {
      taskQueue.addTask(task, taskOwner);
  }
    }


    /**
     * Notifies this service that the channel with the specified {@code

View Full Code Here


    @Test public void scheduleQueuedTasks() throws Exception {
        TaskQueue queue = txnScheduler.createTaskQueue();
        AtomicInteger runCount = new AtomicInteger(0);
        for (int i = 0; i < 10; i++)
            queue.addTask(new DependentTask(runCount), taskOwner);
        Thread.sleep(500L);
        assertEquals(10, runCount.get());
    }


    @Test (expected=NullPointerException.class)

View Full Code Here

    }


    @Test (expected=NullPointerException.class)
        public void scheduleQueuedTasksNull() throws Exception {
        TaskQueue queue = txnScheduler.createTaskQueue();
        queue.addTask(null, taskOwner);
    }


    @Test (expected=NullPointerException.class)
        public void scheduleQueuedTasksOwnerNull() throws Exception {
        TaskQueue queue = txnScheduler.createTaskQueue();

View Full Code Here

    }


    @Test (expected=NullPointerException.class)
        public void scheduleQueuedTasksOwnerNull() throws Exception {
        TaskQueue queue = txnScheduler.createTaskQueue();
        queue.addTask(new DependentTask(null), null);
    }


    /**
     * Test retry policy
     */

View Full Code Here


    @Test public void scheduleQueuedTasks() throws Exception {
        TaskQueue queue = taskScheduler.createTaskQueue();
        AtomicInteger runCount = new AtomicInteger(0);
        for (int i = 0; i < 10; i++)
            queue.addTask(new DependentTask(runCount), taskOwner);
        Thread.sleep(500L);
        assertEquals(10, runCount.get());
    }


    @Test (expected=NullPointerException.class)

View Full Code Here

    }


    @Test (expected=NullPointerException.class)
        public void scheduleQueuedTasksNull() throws Exception {
        TaskQueue queue = taskScheduler.createTaskQueue();
        queue.addTask(null, taskOwner);
    }


    @Test (expected=NullPointerException.class)
        public void scheduleQueuedTasksOwnerNull() throws Exception {
        TaskQueue queue = taskScheduler.createTaskQueue();

View Full Code Here

    }


    @Test (expected=NullPointerException.class)
        public void scheduleQueuedTasksOwnerNull() throws Exception {
        TaskQueue queue = taskScheduler.createTaskQueue();
        queue.addTask(new DependentTask(null), null);
    }


    /**
     * Utility classes.
     */

View Full Code Here

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.