List of runTask() Examples

Examples of runTask()

com.sun.sgs.kernel.TransactionScheduler.runTask()
Runs the given task synchronously, returning when the task has completed or throwing an exception if the task fails. It is up to the {@code TransactionScheduler} implementation to decide when to run thistask, so the task may be run immediately or it might be queued behind waiting tasks. The task may be handed off to another thread of control for execution. In all cases, the caller will block until the task completes or fails permanently.
As with all methods of {@code TransactionScheduler}, tasks run with {@code runTask} will be run transactionally. If the caller is notin an active transaction, then a transaction is created to run the task. If the caller is already part of an active transaction, then the task is run as part of that transaction, and the {@code owner}paramater is ignored.
When the caller is not part of an active transaction, then when the given task completes it will also attempt to commit. If committing the transaction fails, normal re-try behavior is applied. If the task requests to be re-tried, then it will be re-run according to the scheduler implementation's policy. In this case, {@code runTask}will not return until the task finally succeeds, or is no longer re-tried.
In the event that the caller is part of an active transaction, then there is no re-try applied in the case of a failure, and the transaction is not committed if the task completes successfully. This is because the system does not support nested transactions, and so the decision to commit or re-try is left to the active transaction. @param task the {@code KernelRunnable} to execute @param owner the entity on who's behalf this task is run @throws TaskRejectedException if the given task is not accepted @throws InterruptedException if the calling thread is interrupted andthe associated task does not complete @throws Exception if the task fails and is not re-tried
org.apache.roller.weblogger.planet.tasks.RefreshRollerPlanetTask.runTask()
org.apache.roller.weblogger.planet.tasks.SyncWebsitesTask.runTask()
Ensure there's a subscription in the "all" group for every Roller weblog.
org.jboss.util.threadpool.BasicThreadPool.runTask()
org.openbravo.erpCommon.utility.AntExecutor.runTask()
Executes an ant task @param task - Name of the task to execute @throws Exception - In case the project is not loaded

Examples of org.apache.roller.weblogger.planet.tasks.SyncWebsitesTask.runTask()

            PlanetManager planet = PlanetFactory.getPlanet().getPlanetManager();
            
            // run sync task to fill aggregator with websites created by super
            SyncWebsitesTask syncTask = new SyncWebsitesTask();
            syncTask.init();
            syncTask.runTask();
            
            Planet planetObject = planet.getPlanetById("zzz_default_planet_zzz");
            assertNotNull(planetObject);
            PlanetGroup group = planet.getGroup(planetObject, "all");
            assertEquals(1, group.getSubscriptions().size());

View Full Code Here

Examples of org.jboss.util.threadpool.BasicThreadPool.runTask()

   public void testBasic() throws Exception
   {
      BasicThreadPool pool = new BasicThreadPool();
      try
      {
         pool.runTask(new TestTask(BASIC, "test"));
         completed.wait(1);
         HashSet expected = makeExpected(new Object[] {"test"});
         assertEquals(expected, accepted.tasks);
         assertEquals(expected, started.tasks);
         assertEquals(expected, completed.tasks);

View Full Code Here

Examples of org.jboss.util.threadpool.BasicThreadPool.runTask()

   public void testMultipleBasic() throws Exception
   {
      BasicThreadPool pool = new BasicThreadPool();
      try
      {
         pool.runTask(new TestTask(BASIC, "test1"));
         pool.runTask(new TestTask(BASIC, "test2"));
         pool.runTask(new TestTask(BASIC, "test3"));
         completed.wait(3);
         HashSet expected = makeExpected(new Object[] {"test1", "test2", "test3"});
         assertEquals(expected, accepted.tasks);

View Full Code Here

Examples of org.jboss.util.threadpool.BasicThreadPool.runTask()

   {
      BasicThreadPool pool = new BasicThreadPool();
      try
      {
         pool.runTask(new TestTask(BASIC, "test1"));
         pool.runTask(new TestTask(BASIC, "test2"));
         pool.runTask(new TestTask(BASIC, "test3"));
         completed.wait(3);
         HashSet expected = makeExpected(new Object[] {"test1", "test2", "test3"});
         assertEquals(expected, accepted.tasks);
         assertEquals(expected, started.tasks);

View Full Code Here

Examples of org.jboss.util.threadpool.BasicThreadPool.runTask()

      BasicThreadPool pool = new BasicThreadPool();
      try
      {
         pool.runTask(new TestTask(BASIC, "test1"));
         pool.runTask(new TestTask(BASIC, "test2"));
         pool.runTask(new TestTask(BASIC, "test3"));
         completed.wait(3);
         HashSet expected = makeExpected(new Object[] {"test1", "test2", "test3"});
         assertEquals(expected, accepted.tasks);
         assertEquals(expected, started.tasks);
         assertEquals(expected, completed.tasks);

View Full Code Here

Examples of org.jboss.util.threadpool.BasicThreadPool.runTask()

   {
      BasicThreadPool pool = new BasicThreadPool();
      pool.setMaximumPoolSize(1);
      try
      {
         pool.runTask(new TestTask(BASIC, "test1"));
         completed.wait(1);
         pool.runTask(new TestTask(BASIC, "test2"));
         completed.wait(2);
         assertEquals(threadNames.get("test1"), threadNames.get("test2"));
      }

View Full Code Here

Examples of org.jboss.util.threadpool.BasicThreadPool.runTask()

      pool.setMaximumPoolSize(1);
      try
      {
         pool.runTask(new TestTask(BASIC, "test1"));
         completed.wait(1);
         pool.runTask(new TestTask(BASIC, "test2"));
         completed.wait(2);
         assertEquals(threadNames.get("test1"), threadNames.get("test2"));
      }
      finally
      {

View Full Code Here

Examples of org.jboss.util.threadpool.BasicThreadPool.runTask()

   public void testMultiplePooling() throws Exception
   {
      BasicThreadPool pool = new BasicThreadPool();
      try
      {
         pool.runTask(new TestTask(HOLD_START, "test1"));
         started.wait(1);
         pool.runTask(new TestTask(BASIC, "test2"));
         completed.wait(1);
         started.release("test1");
         completed.wait(2);

View Full Code Here

Examples of org.jboss.util.threadpool.BasicThreadPool.runTask()

      BasicThreadPool pool = new BasicThreadPool();
      try
      {
         pool.runTask(new TestTask(HOLD_START, "test1"));
         started.wait(1);
         pool.runTask(new TestTask(BASIC, "test2"));
         completed.wait(1);
         started.release("test1");
         completed.wait(2);
         assertTrue("Shouldn't run on the same thread", threadNames.get("test1").equals(threadNames.get("test2")) == false);
      }

View Full Code Here

Examples of org.jboss.util.threadpool.BasicThreadPool.runTask()

   {
      BasicThreadPool pool = new BasicThreadPool();
      pool.setMaximumPoolSize(1);
      try
      {
         pool.runTask(new TestTask(HOLD_START, "test1"));
         started.wait(1);
         pool.runTask(new TestTask(BASIC, "test2"));
         Thread.sleep(1000);
         assertEquals(0, completed.tasks.size());
         started.release("test1");

View Full Code Here

0 1 2 3 4

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.