reactor-core/src/main/java/reactor/core/publisher/WorkQueueProcessor.java
public static <E> WorkQueueProcessor<E> create(String name, int bufferSize) {
		return WorkQueueProcessor.<E>builder().name(name).bufferSize(bufferSize).build();
	}
public static <E> WorkQueueProcessor<E> create(String name, int bufferSize) {
		return WorkQueueProcessor.<E>builder().name(name).bufferSize(bufferSize).build();
	}
public static < E > WorkQueueProcessor < E > create ( String name , int bufferSize ) { return WorkQueueProcessor . < E > builder ( ) . name ( name ) . bufferSize ( bufferSize ) . build ( ) ; }
Create a new WorkQueueProcessor using the passed buffer size, blockingWait
Strategy and auto-cancel. <p> A new Cached ThreadExecutorPool will be implicitly
created and will use the passed name to qualify the created threads.
@param name Use a new Cached ExecutorService and assign this name to the created
threads
@param bufferSize A Backlog Size to mitigate slow subscribers
@param <E> Type of processed signals
@return a fresh processor
Create a new WorkQueueProcessor using the passed buffer size blockingWait Strategy and auto - cancel . <p > A new Cached ThreadExecutorPool will be implicitly created and will use the passed name to qualify the created threads .