Examples of org.infinispan.util.concurrent.BlockingTaskAwareExecutorServiceImpl

org.infinispan.util.concurrent.BlockingTaskAwareExecutorServiceImpl
A special executor service that accepts a {@code BlockingRunnable}. This special runnable gives hints about the code to be running in order to avoiding put a runnable that will block the thread. In this way, only when the runnable says that is ready, it is sent to the real executor service @author Pedro Ruivo @since 5.3

         executorService.shutdownNow();
      }
   }


   private BlockingTaskAwareExecutorServiceImpl createExecutorService() {
      return new BlockingTaskAwareExecutorServiceImpl(new ThreadPoolExecutor(1, 2, 60, TimeUnit.SECONDS,
                                                                             new LinkedBlockingQueue<Runnable>(1000),
                                                                             new DummyThreadFactory()),
                                                      TIME_SERVICE);
   }

View Full Code Here

   private ReplicableCommand nonBlockingMultipleRpcCommand;


   @BeforeClass
   public void setUp() {
      executorService = new DummyTaskCountExecutorService();
      BlockingTaskAwareExecutorService remoteExecutorService = new BlockingTaskAwareExecutorServiceImpl(executorService,
                                                                                                        TIME_SERVICE);
      ConfigurationBuilder builder = getDefaultCacheConfiguration(false);
      builder.clustering().cacheMode(CacheMode.DIST_SYNC);
      cacheManager = createClusteredCacheManager(builder);
      Cache<Object, Object> cache = cacheManager.getCache();

View Full Code Here

0 1

TOP

Related Classes of org.infinispan.util.concurrent.BlockingTaskAwareExecutorServiceImpl

org.infinispan.executors.BlockingTaskAwareExecutorServiceTest

org.infinispan.executors.LazyInitializingBlockingTaskAwareExecutorService

org.infinispan.remoting.AsynchronousInvocationTest

java.util.concurrent.RejectedExecutionException

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.