org.threadly.concurrent

Class BlockingQueueConsumer<T>

java.lang.Object

org.threadly.util.AbstractService

org.threadly.concurrent.processing.BlockingQueueConsumer<T>

org.threadly.concurrent.BlockingQueueConsumer<T>

Type Parameters:

T - Type of items contained in the queue to be consumed

All Implemented Interfaces:

Service

Deprecated.

See Poller.consumeQueue(java.util.Queue, java.util.function.Consumer) or BlockingQueueConsumer for replacement

@Deprecated
public class BlockingQueueConsumer<T>
extends BlockingQueueConsumer<T>

Migration off this deprecated implementation is highly encouraged. Javadocs removed in 5.37 in replacement for BlockingQueueConsumer. This class slipped under the radar, causing the implementation and interface to be significantly behind in threadly 5.X. Please switch to Poller.consumeQueue(java.util.Queue, java.util.function.Consumer) or BlockingQueueConsumer.

Since:

1.0.0

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	BlockingQueueConsumer.ConsumerAcceptor<T> Deprecated. Interface for an implementation which can accept consumed tasks.

Constructor Summary

Constructors

Constructor and Description
BlockingQueueConsumer(java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.BlockingQueue<? extends T> queue, BlockingQueueConsumer.ConsumerAcceptor<? super T> acceptor) Deprecated. Constructs a new consumer, with a provided queue to consume from, and an acceptor to accept items.
BlockingQueueConsumer(java.util.concurrent.ThreadFactory threadFactory, java.lang.String threadName, java.util.concurrent.BlockingQueue<? extends T> queue, BlockingQueueConsumer.ConsumerAcceptor<? super T> acceptor) Deprecated. Constructs a new consumer, with a provided queue to consume from, and an acceptor to accept items.

Method Summary

Methods inherited from class org.threadly.concurrent.processing.BlockingQueueConsumer

makeForHandlers

Methods inherited from class org.threadly.util.AbstractService

hasStopped, isRunning, start, startIfNotStarted, stop, stopIfRunning

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingQueueConsumer

public BlockingQueueConsumer(java.util.concurrent.ThreadFactory threadFactory,
                             java.util.concurrent.BlockingQueue<? extends T> queue,
                             BlockingQueueConsumer.ConsumerAcceptor<? super T> acceptor)

Deprecated.

Constructs a new consumer, with a provided queue to consume from, and an acceptor to accept items.

Parameters:

threadFactory - ThreadFactory to construct new thread for consumer to run on

queue - queue to consume from

acceptor - acceptor to provide consumed items to

BlockingQueueConsumer

public BlockingQueueConsumer(java.util.concurrent.ThreadFactory threadFactory,
                             java.lang.String threadName,
                             java.util.concurrent.BlockingQueue<? extends T> queue,
                             BlockingQueueConsumer.ConsumerAcceptor<? super T> acceptor)

Deprecated.

Constructs a new consumer, with a provided queue to consume from, and an acceptor to accept items.

Parameters:

threadFactory - ThreadFactory to construct new thread for consumer to run on

threadName - Name of thread consumer runs on, or null to generate a default one

queue - queue to consume from

acceptor - acceptor to provide consumed items to