本文整理了Java中org.glassfish.grizzly.Transport.getWorkerThreadPool()方法的一些代码示例，展示了Transport.getWorkerThreadPool()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Transport.getWorkerThreadPool()方法的具体详情如下：
包路径：org.glassfish.grizzly.Transport
类名称：Transport
方法名：getWorkerThreadPool

Transport.getWorkerThreadPool介绍

[英]Get a thread pool, which will run IOEvent processing (depending on Transport IOStrategy) to let kernel threads continue their job.
[中]获取一个线程池，它将运行IOEvent处理（取决于传输IOStrategy），让内核线程继续工作。

代码示例

代码示例来源：origin: com.ning/async-http-client

private void feederFlush(final Connection c) {
  if (isServiceThread()) {
    c.getTransport().getWorkerThreadPool().execute(new Runnable() {
      @Override
      public void run() {
        feederFlush0(c);
      }
    });
  } else {
    feederFlush0(c);
  }
}

代码示例来源：origin: javaee/grizzly

@Override
public Executor getThreadPoolFor(final Connection connection,
    final IOEvent ioEvent) {
  return WORKER_THREAD_EVENT_SET.contains(ioEvent) ?
      connection.getTransport().getWorkerThreadPool() :
      null;
}

代码示例来源：origin: javaee/grizzly

@Override
public Executor getThreadPoolFor(final Connection connection,
    final IOEvent ioEvent) {
  return WORKER_THREAD_EVENT_SET.contains(ioEvent) ?
      connection.getTransport().getWorkerThreadPool() :
      null;
}

代码示例来源：origin: javaee/grizzly

@Override
public Executor getThreadPoolFor(final Connection connection,
    final IOEvent ioEvent) {
  return WORKER_THREAD_EVENT_SET.contains(ioEvent) ?
      connection.getTransport().getWorkerThreadPool() :
      null;
}

代码示例来源：origin: javaee/grizzly

@Override
public Executor getThreadPoolFor(final Connection connection,
    final IOEvent ioEvent) {
  return WORKER_THREAD_EVENT_SET.contains(ioEvent) ?
      connection.getTransport().getWorkerThreadPool() :
      null;
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-core

@Override
public Executor getThreadPoolFor(final Connection connection,
    final IOEvent ioEvent) {
  return WORKER_THREAD_EVENT_SET.contains(ioEvent) ?
      connection.getTransport().getWorkerThreadPool() :
      null;
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-server-core

@Override
public Executor getThreadPoolFor(final Connection connection,
    final IOEvent ioEvent) {
  return WORKER_THREAD_EVENT_SET.contains(ioEvent) ?
      connection.getTransport().getWorkerThreadPool() :
      null;
}

代码示例来源：origin: javaee/grizzly

@Override
public Executor getThreadPoolFor(final Connection connection,
    final IOEvent ioEvent) {
  return WORKER_THREAD_EVENT_SET.contains(ioEvent) ?
      connection.getTransport().getWorkerThreadPool() :
      null;
}

代码示例来源：origin: javaee/grizzly

@Override
public Executor getThreadPoolFor(final Connection connection,
    final IOEvent ioEvent) {
  return WORKER_THREAD_EVENT_SET.contains(ioEvent) ?
      connection.getTransport().getWorkerThreadPool() :
      null;
}

代码示例来源：origin: javaee/grizzly

@Override
public Executor getThreadPoolFor(final Connection connection,
    final IOEvent ioEvent) {
  return WORKER_THREAD_EVENT_SET.contains(ioEvent) ?
      connection.getTransport().getWorkerThreadPool() :
      null;
}

代码示例来源：origin: javaee/grizzly

private void submit(final Connection c, final Runnable runnable) {
  if (threadPool != null) {
    threadPool.submit(runnable);
  } else {
    final Transport t = c.getTransport();
    final ExecutorService workerThreadPool = t.getWorkerThreadPool();
    if (workerThreadPool != null) {
      workerThreadPool.submit(runnable);
    } else {
      t.getKernelThreadPool().submit(runnable);
    }
  }
}

代码示例来源：origin: javaee/grizzly

/**
 * @return {@link Executor}, which will be used for notifying user
 * registered {@link WriteHandler}.
 */
protected Executor getThreadPool() {
  if (!Threads.isService()) {
    return null;
  }
  
  final ExecutorService es = connection.getTransport().getWorkerThreadPool();
  return es != null && !es.isShutdown() ? es : null;
}

代码示例来源：origin: javaee/grizzly

/**
 * @return {@link Executor}, which will be used for notifying user
 * registered {@link WriteHandler}.
 */
protected Executor getThreadPool() {
  if (!Threads.isService()) {
    return null;
  }
  
  final ExecutorService es = connection.getTransport().getWorkerThreadPool();
  return es != null && !es.isShutdown() ? es : null;
}

代码示例来源：origin: javaee/grizzly

/**
 * @return {@link Executor}, which will be used for notifying user
 * registered {@link WriteHandler}.
 */
protected Executor getThreadPool() {
  if (!Threads.isService()) {
    return null;
  }
  
  final ExecutorService es = connection.getTransport().getWorkerThreadPool();
  return es != null && !es.isShutdown() ? es : null;
}

代码示例来源：origin: javaee/grizzly

/**
 * @return {@link Executor}, which will be used for notifying user
 * registered {@link ReadHandler}.
 */
protected Executor getThreadPool() {
  if (!Threads.isService()) {
    return null;
  }
  final ExecutorService es = connection.getTransport().getWorkerThreadPool();
  return es != null && !es.isShutdown() ? es : null;
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http

/**
 * @return {@link Executor}, which will be used for notifying user
 * registered {@link WriteHandler}.
 */
protected Executor getThreadPool() {
  if (!Threads.isService()) {
    return null;
  }
  
  final ExecutorService es = connection.getTransport().getWorkerThreadPool();
  return es != null && !es.isShutdown() ? es : null;
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http

/**
 * @return {@link Executor}, which will be used for notifying user
 * registered {@link ReadHandler}.
 */
protected Executor getThreadPool() {
  if (!Threads.isService()) {
    return null;
  }
  final ExecutorService es = connection.getTransport().getWorkerThreadPool();
  return es != null && !es.isShutdown() ? es : null;
}

代码示例来源：origin: javaee/grizzly

/**
 * @return {@link Executor}, which will be used for notifying user
 * registered {@link WriteHandler}.
 */
protected Executor getThreadPool() {
  if (!Threads.isService()) {
    return null;
  }
  
  final ExecutorService es = connection.getTransport().getWorkerThreadPool();
  return es != null && !es.isShutdown() ? es : null;
}

代码示例来源：origin: javaee/grizzly

/**
 * @return {@link Executor}, which will be used for notifying user
 * registered {@link WriteHandler}.
 */
protected Executor getThreadPool() {
  if (!Threads.isService()) {
    return null;
  }
  
  final ExecutorService es = connection.getTransport().getWorkerThreadPool();
  return es != null && !es.isShutdown() ? es : null;
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http-server

@Override
  public Executor getExecutor(final Request request) {
    if (!Threads.isService()) {
      return null; // Execute in the current thread
    }
    return request.getContext().getConnection().getTransport().getWorkerThreadPool();
  }
}