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();
	}
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