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

HttpClient.setScheduler介绍

暂无

代码示例

代码示例来源：origin: spring-projects/spring-framework

/**
 * Constructor with an {@link JettyResourceFactory} that will manage shared resources.
 * @param resourceFactory the {@link JettyResourceFactory} to use
 * @param customizer the lambda used to customize the {@link HttpClient}
 */
public JettyClientHttpConnector(
    JettyResourceFactory resourceFactory, @Nullable Consumer<HttpClient> customizer) {
  HttpClient httpClient = new HttpClient();
  httpClient.setExecutor(resourceFactory.getExecutor());
  httpClient.setByteBufferPool(resourceFactory.getByteBufferPool());
  httpClient.setScheduler(resourceFactory.getScheduler());
  if (customizer != null) {
    customizer.accept(httpClient);
  }
  this.httpClient = httpClient;
}

代码示例来源：origin: org.springframework/spring-web

/**
 * Constructor with an {@link JettyResourceFactory} that will manage shared resources.
 * @param resourceFactory the {@link JettyResourceFactory} to use
 * @param customizer the lambda used to customize the {@link HttpClient}
 */
public JettyClientHttpConnector(
    JettyResourceFactory resourceFactory, @Nullable Consumer<HttpClient> customizer) {
  HttpClient httpClient = new HttpClient();
  httpClient.setExecutor(resourceFactory.getExecutor());
  httpClient.setByteBufferPool(resourceFactory.getByteBufferPool());
  httpClient.setScheduler(resourceFactory.getScheduler());
  if (customizer != null) {
    customizer.accept(httpClient);
  }
  this.httpClient = httpClient;
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.spring-web

/**
 * Constructor with an {@link JettyResourceFactory} that will manage shared resources.
 * @param resourceFactory the {@link JettyResourceFactory} to use
 * @param customizer the lambda used to customize the {@link HttpClient}
 */
public JettyClientHttpConnector(
    JettyResourceFactory resourceFactory, @Nullable Consumer<HttpClient> customizer) {
  HttpClient httpClient = new HttpClient();
  httpClient.setExecutor(resourceFactory.getExecutor());
  httpClient.setByteBufferPool(resourceFactory.getByteBufferPool());
  httpClient.setScheduler(resourceFactory.getScheduler());
  if (customizer != null) {
    customizer.accept(httpClient);
  }
  this.httpClient = httpClient;
}

代码示例来源：origin: apache/servicemix-bundles

/**
 * Constructor with an {@link JettyResourceFactory} that will manage shared resources.
 * @param resourceFactory the {@link JettyResourceFactory} to use
 * @param customizer the lambda used to customize the {@link HttpClient}
 */
public JettyClientHttpConnector(
    JettyResourceFactory resourceFactory, @Nullable Consumer<HttpClient> customizer) {
  HttpClient httpClient = new HttpClient();
  httpClient.setExecutor(resourceFactory.getExecutor());
  httpClient.setByteBufferPool(resourceFactory.getByteBufferPool());
  httpClient.setScheduler(resourceFactory.getScheduler());
  if (customizer != null) {
    customizer.accept(httpClient);
  }
  this.httpClient = httpClient;
}

代码示例来源：origin: airlift/airlift

httpClient.setScheduler(createScheduler(name, config.getTimeoutConcurrency(), config.getTimeoutThreads()));

代码示例来源：origin: com.proofpoint.platform/http-client

httpClient.setScheduler(createScheduler(name, config.getTimeoutConcurrency(), config.getTimeoutThreads()));

代码示例来源：origin: org.eclipse.jetty/jetty-client

@Override
protected void doStart() throws Exception
{
  if (executor == null)
  {
    QueuedThreadPool threadPool = new QueuedThreadPool();
    threadPool.setName(name);
    setExecutor(threadPool);
  }
  if (byteBufferPool == null)
    setByteBufferPool(new MappedByteBufferPool(2048,
        executor instanceof ThreadPool.SizedThreadPool
            ? ((ThreadPool.SizedThreadPool)executor).getMaxThreads() / 2
            : ProcessorUtils.availableProcessors() * 2));
  if (scheduler == null)
    setScheduler(new ScheduledExecutorScheduler(name + "-scheduler", false));
  if (resolver == null)
    setSocketAddressResolver(new SocketAddressResolver.Async(executor, scheduler, getAddressResolutionTimeout()));
  handlers.put(new ContinueProtocolHandler());
  handlers.put(new RedirectProtocolHandler(this));
  handlers.put(new WWWAuthenticationProtocolHandler(this));
  handlers.put(new ProxyAuthenticationProtocolHandler(this));
  decoderFactories.add(new GZIPContentDecoder.Factory(byteBufferPool));
  cookieManager = newCookieManager();
  cookieStore = cookieManager.getCookieStore();
  transport.setHttpClient(this);
  super.doStart();
}