Examples of WorkerService

org.apache.zookeeper.server.WorkerService
WorkerService is a worker thread pool for running tasks and is implemented using one or more ExecutorServices. A WorkerService can support assignable threads, which it does by creating N separate single thread ExecutorServices, or non-assignable threads, which it does by creating a single N-thread ExecutorService. - NIOServerCnxnFactory uses a non-assignable WorkerService because the socket IO requests are order independent and allowing the ExecutorService to handle thread assignment gives optimal performance. - CommitProcessor uses an assignable WorkerService because requests for a given session must be processed in order. ExecutorService provides queue management and thread restarting, so it's useful even with a single thread.
org.exoplatform.services.jcr.impl.proccess.WorkerService
WorkerService. @author Karpenko Sergiy @version $Id: WorkerService.java 34361 2010-08-24 23:58:59Z aheritier $
org.wildfly.extension.io.WorkerService

Examples of org.apache.zookeeper.server.WorkerService

          false);
        }


        public void testStart() {
            this.stopped = false;
            this.workerPool = new WorkerService(
                    "CommitProcWork", 1, true);
        }

View Full Code Here

Examples of org.apache.zookeeper.server.WorkerService


        LOG.info("Configuring CommitProcessor with "
                 + (numWorkerThreads > 0 ? numWorkerThreads : "no")
                 + " worker threads.");
        if (workerPool == null) {
            workerPool = new WorkerService(
                "CommitProcWork", numWorkerThreads, true);
        }
        stopped = false;
        super.start();
    }

View Full Code Here

Examples of org.exoplatform.services.jcr.impl.proccess.WorkerService

         if (entry.getLockRemoverThreadsCount() > 0)
         {
            threadCount = entry.getLockRemoverThreadsCount();
         }
      }
      workerService = new WorkerService(threadCount, "lock-remover");
   }

View Full Code Here

Examples of org.exoplatform.services.jcr.impl.proccess.WorkerService

         if (entry.getLockRemoverThreadsCount() > 0)
         {
            threadCount = entry.getLockRemoverThreadsCount();
         }
      }
      workerService = new WorkerService(threadCount, "lock-remover");
   }

View Full Code Here

Examples of org.exoplatform.services.jcr.impl.proccess.WorkerService

      if (entry != null && entry.getLockRemoverThreadsCount() > 0)
      {
         threadCount = entry.getLockRemoverThreadsCount();
      }
      workerService =
               new WorkerService(threadCount, "Lock Remover "
                        + (ctx != null ? ctx.getName() : (entry == null ? "" : entry.getName())));
   }

View Full Code Here

Examples of org.exoplatform.services.jcr.impl.proccess.WorkerService

         if (entry.getLockRemoverThreadsCount() > 0)
         {
            threadCount = entry.getLockRemoverThreadsCount();
         }
      }
      workerService = new WorkerService(threadCount, "lock-remover-" + entry.getName());
   }

View Full Code Here

Examples of org.wildfly.extension.io.WorkerService

                    .install();
            target.addService(ContextNames.JBOSS_CONTEXT_SERVICE_NAME, new NamingStoreService())
                    .setInitialMode(ServiceController.Mode.ACTIVE)
                    .install();


            target.addService(IOServices.WORKER.append("default"), new WorkerService(OptionMap.builder().set(Options.WORKER_IO_THREADS, 2).getMap()))
                    .setInitialMode(ServiceController.Mode.ACTIVE)
                    .install();


            target.addService(IOServices.BUFFER_POOL.append("default"), new BufferPoolService(2048, 2048, true))
                    .setInitialMode(ServiceController.Mode.ACTIVE)

View Full Code Here

Examples of org.wildfly.extension.io.WorkerService

                    .install();
            target.addService(ContextNames.JBOSS_CONTEXT_SERVICE_NAME, new NamingStoreService())
                    .setInitialMode(ServiceController.Mode.ACTIVE)
                    .install();


            target.addService(IOServices.WORKER.append("default"), new WorkerService(OptionMap.builder().set(Options.WORKER_IO_THREADS, 2).getMap()))
                    .setInitialMode(ServiceController.Mode.ACTIVE)
                    .install();


            target.addService(IOServices.BUFFER_POOL.append("default"), new BufferPoolService(2048, 2048, true))
                    .setInitialMode(ServiceController.Mode.ACTIVE)

View Full Code Here

Examples of org.wildfly.extension.io.WorkerService

                    .install();
            target.addService(ContextNames.JBOSS_CONTEXT_SERVICE_NAME, new NamingStoreService())
                    .setInitialMode(ServiceController.Mode.ACTIVE)
                    .install();


            target.addService(IOServices.WORKER.append("default"), new WorkerService(OptionMap.builder().set(Options.WORKER_IO_THREADS, 2).getMap()))
                    .setInitialMode(ServiceController.Mode.ACTIVE)
                    .install();


            target.addService(IOServices.BUFFER_POOL.append("default"), new BufferPoolService(2048, 2048, true))
                    .setInitialMode(ServiceController.Mode.ACTIVE)

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.