Package com.xxl.tool.concurrent

Class MessageQueue<T>

java.lang.Object

com.xxl.tool.concurrent.MessageQueue<T>

public class MessageQueue<T>
extends Object

producer-consumer queue

Author:

xuxueli 2025-04-12

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MessageQueue.MessageConsumer<T>	Message Consumer

Constructor Summary

Constructors

Constructor	Description
MessageQueue(String name, int queueLength, MessageQueue.MessageConsumer<T> consumer, int consumerCount, int consumeBatchSize)	default constructor
MessageQueue(String name, MessageQueue.MessageConsumer<T> consumer)
MessageQueue(String name, MessageQueue.MessageConsumer<T> consumer, int consumeBatchSize)
MessageQueue(String name, MessageQueue.MessageConsumer<T> consumer, int consumerCount, int consumeBatchSize)

Method Summary

Modifier and Type	Method	Description
boolean	produce(T message)	produce message
void	stop()	stop

Methods inherited from class java.lang.Object

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

Constructor Details

MessageQueue

public MessageQueue(String name,
 MessageQueue.MessageConsumer<T> consumer)

MessageQueue

public MessageQueue(String name,
 MessageQueue.MessageConsumer<T> consumer,
 int consumeBatchSize)

MessageQueue

public MessageQueue(String name,
 MessageQueue.MessageConsumer<T> consumer,
 int consumerCount,
 int consumeBatchSize)

MessageQueue

public MessageQueue(String name,
 int queueLength,
 MessageQueue.MessageConsumer<T> consumer,
 int consumerCount,
 int consumeBatchSize)

default constructor

Parameters:

queueLength - queue max length

consumerCount - consumer thread count

consumer - consumer method

Method Details

produce

public boolean produce(T message)

produce message

Parameters:

message -

Returns:

Throws:

InterruptedException

stop

public void stop()

stop