com.booking.validator.utils

Class ConcurrentPipeline<T>

java.lang.Object

com.booking.validator.utils.ConcurrentPipeline<T>

All Implemented Interfaces:

Service

public class ConcurrentPipeline<T>
extends Object
implements Service

Created by psalimov on 9/7/16. This class implements concurrent execution of the sequence: 1) fetch a task (that is a supplier of a completable future) from the supplier 2) execute the task 3) feed the consumer with the task result or with the error such a way that no more then the specified number of tasks are being processed simultaneously. The supplier and consumer must be thread safe.

Constructor Summary

Constructors

Constructor and Description
ConcurrentPipeline(java.util.function.Supplier<? extends java.util.function.Supplier<CompletableFuture<T>>> supplier, java.util.function.BiConsumer<T,Throwable> consumer, int concurrencyLimit)

Method Summary

Modifier and Type	Method and Description
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.booking.validator.utils.Service

pause, resume

Constructor Detail

ConcurrentPipeline

public ConcurrentPipeline(java.util.function.Supplier<? extends java.util.function.Supplier<CompletableFuture<T>>> supplier,
                          java.util.function.BiConsumer<T,Throwable> consumer,
                          int concurrencyLimit)

Method Detail

start

public void start()

Specified by:

start in interface Service

stop

public void stop()

Specified by:

stop in interface Service