ExecutorService getExecutor(int asyncThreads) {
  // TODO(carl-mastrangelo): This should not be necessary.  I don't know where this should be
  // put.  Move it somewhere else, or remove it if no longer necessary.
  // See: https://github.com/grpc/grpc-java/issues/2119
  return new ForkJoinPool(asyncThreads,
      new ForkJoinWorkerThreadFactory() {
        final AtomicInteger num = new AtomicInteger();
        @Override
        public ForkJoinWorkerThread newThread(ForkJoinPool pool) {
          ForkJoinWorkerThread thread = defaultForkJoinWorkerThreadFactory.newThread(pool);
          thread.setDaemon(true);
          thread.setName("server-worker-" + "-" + num.getAndIncrement());
          return thread;
        }
      }, UncaughtExceptionHandlers.systemExit(), true /* async */);
}
 

ExecutorService getExecutor(int asyncThreads) {
  // TODO(carl-mastrangelo): This should not be necessary.  I don't know where this should be
  // put.  Move it somewhere else, or remove it if no longer necessary.
  // See: https://github.com/grpc/grpc-java/issues/2119
  return new ForkJoinPool(asyncThreads,
      new ForkJoinWorkerThreadFactory() {
        final AtomicInteger num = new AtomicInteger();
        @Override
        public ForkJoinWorkerThread newThread(ForkJoinPool pool) {
          ForkJoinWorkerThread thread = defaultForkJoinWorkerThreadFactory.newThread(pool);
          thread.setDaemon(true);
          thread.setName("server-worker-" + "-" + num.getAndIncrement());
          return thread;
        }
      }, UncaughtExceptionHandlers.systemExit(), true /* async */);
}
 

public static void main(String[] args) {
  Thread.setDefaultUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit());

  WorkerMain workerMain = new WorkerMain();
  workerMain.initialize();
  workerMain.poll();

  System.exit(0);
}
 

public static void main(String[] args) {
  Thread.setDefaultUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit());

  SingleVMMain singleVMMain = new SingleVMMain();

  Runtime.getRuntime().addShutdownHook(new Thread(singleVMMain::shutdown));

  // TODO make number of workers configurable
  singleVMMain.initializeWorkers(1);
  singleVMMain.initializeGateway();
}
 

/**
 * Separated out for easy overriding in tests.
 */
@VisibleForTesting
protected ExecutorService createSingleThreadExecutor() {
  return Executors.newSingleThreadExecutor(
      new ThreadFactoryBuilder()
        .setDaemon(true)
        .setNameFormat("Logger channel (from single-thread executor) to " +
            addr)
        .setUncaughtExceptionHandler(
            UncaughtExceptionHandlers.systemExit())
        .build());
}
 

/**
 * Separated out for easy overriding in tests.
 */
@VisibleForTesting
protected ExecutorService createParallelExecutor() {
  return Executors.newCachedThreadPool(
      new ThreadFactoryBuilder()
          .setDaemon(true)
          .setNameFormat("Logger channel (from parallel executor) to " + addr)
          .setUncaughtExceptionHandler(
              UncaughtExceptionHandlers.systemExit())
          .build());
}
 

/**
 * Separated out for easy overriding in tests.
 */
@VisibleForTesting
protected ExecutorService createSingleThreadExecutor() {
  return Executors.newSingleThreadExecutor(
      new ThreadFactoryBuilder()
        .setDaemon(true)
        .setNameFormat("Logger channel (from single-thread executor) to " +
            addr)
        .setUncaughtExceptionHandler(
            UncaughtExceptionHandlers.systemExit())
        .build());
}
 

/**
 * Separated out for easy overriding in tests.
 */
@VisibleForTesting
protected ExecutorService createParallelExecutor() {
  return Executors.newCachedThreadPool(
      new ThreadFactoryBuilder()
          .setDaemon(true)
          .setNameFormat("Logger channel (from parallel executor) to " + addr)
          .setUncaughtExceptionHandler(
              UncaughtExceptionHandlers.systemExit())
          .build());
}
 

public static void main(String[] args) throws Exception {
	Thread.currentThread().setUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit());

	maybeEnableDemo();

	Server server = new Server(PORT);

	ServletContextHandler contextHandler = new ServletContextHandler(server, "/");
	addDefaultServlet(contextHandler);

	addJerseyServlet(contextHandler);
	addCorHeadersFilter(contextHandler);

	server.start();
	server.join();
}