Examples of com.level3.meanwhile.TaskQueue

com.level3.meanwhile.state.ClaimCheck
Class that creates and manages a java thread pool for use in executing generic asynchronous tasks. There may be many of these pools available per JVM.
Currently backed by a boundless LinkedBlockingQueue. This means that the queue will continue to grow infinitely. May want to consider bounding this in the future and throwing exceptions if queue length exceeded. @author Jonathan Griggs @since 0.1

            @Override
            public boolean execute() {
                throw new UnsupportedOperationException("Not supported yet.");
            }
        }, manager);
        MeanwhileFuture future = new MeanwhileFuture(runner);
        assertTrue(future.equals(future));
        assertTrue(future.hashCode()==future.hashCode());
        assertTrue(runner.equals(runner));
        assertTrue(runner.hashCode()==runner.hashCode());
    }

View Full Code Here

         * @see ClaimCheck
         * @see Future
         */
  public <T extends Task> ClaimCheck execute(final T task) {
    startUp();
                MeanwhileFuture<T> future = new MeanwhileFuture<T>(new MeanwhileRunner(task,this));
                if(task instanceof Stage) {
                    stagePool.execute(future);
                } else {
                    pool.execute(future);
                }

View Full Code Here

         * @see Task
         * @see Future
         */
  public <T extends Task> MeanwhileFuture<T> submit(final T task) {
    startUp();
                MeanwhileFuture<T> future = new MeanwhileFuture<T>(new MeanwhileRunner(task,this));
                if(task instanceof Stage) {
                    stagePool.execute(future);
                } else {
                    pool.execute(future);
                }

View Full Code Here

        assertFalse(check2.equals(check1));
    }
    
    @Test
    public void coverageHacks() throws Exception {
        MeanwhileRunner runner = new MeanwhileRunner(new BaseTask() {


            @Override
            public boolean execute() {
                throw new UnsupportedOperationException("Not supported yet.");
            }
        }, manager);
        MeanwhileFuture future = new MeanwhileFuture(runner);
        assertTrue(future.equals(future));
        assertTrue(future.hashCode()==future.hashCode());
        assertTrue(runner.equals(runner));
        assertTrue(runner.hashCode()==runner.hashCode());
    }

View Full Code Here

   * @since 0.1
         */
  private void startUp(final int maxNumThreads, final int maxNumStageThreads) {
    if(!isPoolStarted()) {
      queue = new LinkedBlockingQueue<Runnable>();
      pool = new MeanwhileThreadPoolExecutor(maxNumThreads, maxNumThreads, 0, TimeUnit.SECONDS, queue);
    }
                if(!isStagePoolStarted()) {
                        stageQueue = new LinkedBlockingQueue<Runnable>();
      stagePool = new MeanwhileThreadPoolExecutor(maxNumStageThreads, maxNumStageThreads, 0, TimeUnit.SECONDS, stageQueue);
    } 
  }

View Full Code Here

     */
    private TaskStatus status = TaskStatus.DEQUEUED;
    
    public MeanwhileRunner(final T task, final TaskQueue manager) {
        this.manager = manager;
        claimCheck = new ClaimCheck(task.getUUID());
        init(task);
    }

View Full Code Here

        init(task);
    }
    
    public MeanwhileRunner(final T task, final TaskQueue manager, final ClaimCheck parentCheck) {
        this.manager = manager;
        claimCheck = new ClaimCheck(task.getUUID(),parentCheck);
        init(task);
    }

View Full Code Here

        task1.chain(task2);
        task2.chain(task3);
        task3.chain(task4);
        task4.chain(task5);
        
        ClaimCheck claim = manager.execute(task1);
        ClaimCheck indClaim = manager.execute(independentTask);
        
        stopWatch.block(300);
        assertEquals("Task 1 is SUCCESS",TaskStatus.SUCCESS,task1.getStatus());
        assertEquals("Task 2 is WORKING",TaskStatus.WORKING,task2.getStatus());
        assertEquals("Task 3 is DEQUEUED",TaskStatus.DEQUEUED,task3.getStatus());

View Full Code Here

        task1.chain(task2);
        task2.chain(task3);
        task3.chain(task4);
        task4.chain(task5);
        
        ClaimCheck claim = manager.execute(task1);
        ClaimCheck indClaim = manager.execute(independentTask);
        
        stopWatch.block(300);
        assertEquals("Task 1 is SUCCESS",TaskStatus.SUCCESS,task1.getStatus());
        assertEquals("Task 2 is WORKING",TaskStatus.WORKING,task2.getStatus());
        assertEquals("Task 3 is DEQUEUED",TaskStatus.DEQUEUED,task3.getStatus());
        assertEquals("Task 4 is DEQUEUED",TaskStatus.DEQUEUED,task4.getStatus());
        assertEquals("Task 5 is DEQUEUED",TaskStatus.DEQUEUED,task5.getStatus());
        
        stopWatch.block(250);
        assertEquals("Task 1 is SUCCESS",TaskStatus.SUCCESS,task1.getStatus());
        assertEquals("Task 2 is SUCCESS",TaskStatus.SUCCESS,task2.getStatus());
        assertEquals("Task 3 is WORKING",TaskStatus.WORKING,task3.getStatus());
        assertEquals("Task 4 is DEQUEUED",TaskStatus.DEQUEUED,task4.getStatus());
        assertEquals("Task 5 is DEQUEUED",TaskStatus.DEQUEUED,task5.getStatus());
        
        boolean indSuccess = manager.block(indClaim.toString());
        assertFalse("Independent Block was unsuccessful",indSuccess); 
        
        boolean success = manager.block(claim.toString());
        assertTrue("Block was successful",success);
        assertEquals("Task 1 is SUCCESS",TaskStatus.SUCCESS,task1.getStatus());

View Full Code Here

        task1.chain(task2);
        task2.chain(task3);
        task3.chain(task4);
        task4.chain(task5);
        
        ClaimCheck claim = manager.execute(task1);
        ClaimCheck indClaim = manager.execute(independentTask);
        
        stopWatch.block(300);
        assertEquals("Task 1 is SUCCESS",TaskStatus.SUCCESS,task1.getStatus());
        assertEquals("Task 2 is WORKING",TaskStatus.WORKING,task2.getStatus());
        assertEquals("Task 3 is DEQUEUED",TaskStatus.DEQUEUED,task3.getStatus());
        assertEquals("Task 4 is DEQUEUED",TaskStatus.DEQUEUED,task4.getStatus());
        assertEquals("Task 5 is DEQUEUED",TaskStatus.DEQUEUED,task5.getStatus());
        
        stopWatch.block(250);
        assertEquals("Task 1 is SUCCESS",TaskStatus.SUCCESS,task1.getStatus());
        assertEquals("Task 2 is SUCCESS",TaskStatus.SUCCESS,task2.getStatus());
        assertEquals("Task 3 is WORKING",TaskStatus.WORKING,task3.getStatus());
        assertEquals("Task 4 is DEQUEUED",TaskStatus.DEQUEUED,task4.getStatus());
        assertEquals("Task 5 is DEQUEUED",TaskStatus.DEQUEUED,task5.getStatus());
        
        boolean indSuccess = manager.block(UUID.fromString(indClaim.toString()));
        assertFalse("Independent Block was unsuccessful",indSuccess); 
        
        boolean success = manager.block(UUID.fromString(claim.toString()));
        assertTrue("Block was successful",success);
        assertEquals("Task 1 is SUCCESS",TaskStatus.SUCCESS,task1.getStatus());

View Full Code Here

0 1 2 3 4 5 6

TOP

Related Classes of com.level3.meanwhile.TaskQueue

com.level3.meanwhile.base.BaseChain

com.level3.meanwhile.base.BaseTask

com.level3.meanwhile.ChainTest

com.level3.meanwhile.concurrent.MeanwhileFuture

com.level3.meanwhile.concurrent.MeanwhileRunner

com.level3.meanwhile.concurrent.MeanwhileThreadPoolExecutor

com.level3.meanwhile.MiscTest

com.level3.meanwhile.StageTest

com.level3.meanwhile.state.ClaimCheck

com.level3.meanwhile.state.TaskStatus

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.