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

WorkQueueProcessor.<init>介绍

暂无

代码示例

代码示例来源：origin: reactor/reactor-core

/**
   * Creates a new {@link WorkQueueProcessor} using the properties
   * of this builder.
   * @return a fresh processor
   */
  public WorkQueueProcessor<T>  build() {
    String name = this.name != null ? this.name : WorkQueueProcessor.class.getSimpleName();
    WaitStrategy waitStrategy = this.waitStrategy != null ? this.waitStrategy : WaitStrategy.liteBlocking();
    ThreadFactory threadFactory = this.executor != null ? null : new EventLoopFactory(name, autoCancel);
    ExecutorService requestTaskExecutor = this.requestTaskExecutor != null ?
        this.requestTaskExecutor : defaultRequestTaskExecutor(defaultName(threadFactory, WorkQueueProcessor.class));
    return new WorkQueueProcessor<>(
        threadFactory,
        executor,
        requestTaskExecutor,
        bufferSize,
        waitStrategy,
        share,
        autoCancel);
  }
}

代码示例来源：origin: reactor/reactor-core

@Test
public void customRequestTaskThreadRejectsNull() {
  ExecutorService customTaskExecutor = null;
  Assertions.assertThatExceptionOfType(NullPointerException.class)
       .isThrownBy(() -> new WorkQueueProcessor<>(
           Thread::new,
           Executors.newCachedThreadPool(),
           customTaskExecutor,
           8, WaitStrategy.liteBlocking(), true, true)
       );
}

代码示例来源：origin: io.projectreactor/reactor-core

/**
   * Creates a new {@link WorkQueueProcessor} using the properties
   * of this builder.
   * @return a fresh processor
   */
  public WorkQueueProcessor<T>  build() {
    String name = this.name != null ? this.name : WorkQueueProcessor.class.getSimpleName();
    WaitStrategy waitStrategy = this.waitStrategy != null ? this.waitStrategy : WaitStrategy.liteBlocking();
    ThreadFactory threadFactory = this.executor != null ? null : new EventLoopFactory(name, autoCancel);
    ExecutorService requestTaskExecutor = this.requestTaskExecutor != null ?
        this.requestTaskExecutor : defaultRequestTaskExecutor(defaultName(threadFactory, WorkQueueProcessor.class));
    return new WorkQueueProcessor<>(
        threadFactory,
        executor,
        requestTaskExecutor,
        bufferSize,
        waitStrategy,
        share,
        autoCancel);
  }
}