org.dromara.hutool.core.lang.event

Class SimpleEventPublisher

java.lang.Object

org.dromara.hutool.core.lang.event.SimpleEventPublisher

All Implemented Interfaces:

EventPublisher

public class SimpleEventPublisher
extends Object
implements EventPublisher

简单的事件发布者实现，基于Subscriber和Event实现

Since:

6.0.0

Author:

looly

Constructor Summary

Constructors

Constructor and Description
SimpleEventPublisher(List<Subscriber> subscribers, Loader<ExecutorService> executorServiceLoader) 构造

Method Summary

Modifier and Type	Method and Description
static SimpleEventPublisher	of() 创建一个默认的SimpleEventPublisher，默认线程池为ThreadUtil.newExecutor()
static SimpleEventPublisher	of(List<Subscriber> subscribers) 创建一个默认的SimpleEventPublisher，默认线程池为ThreadUtil.newExecutor()
void	publish(Event event) 发布事件，事件发布者将事件发布给所有订阅者
EventPublisher	register(Subscriber subscriber) 注册订阅者，订阅者将接收到所有发布者发布的事件
SimpleEventPublisher	setExecutorService(ExecutorService executorService) 设置自定义的ExecutorService线程池，默认为ThreadUtil.newExecutor()

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleEventPublisher

public SimpleEventPublisher(List<Subscriber> subscribers,
                            Loader<ExecutorService> executorServiceLoader)

构造

Parameters:

subscribers - 订阅者列表

executorServiceLoader - 线程池加载器，用于异步执行，默认为ThreadUtil.newExecutor()

Method Detail

of

public static SimpleEventPublisher of()

创建一个默认的SimpleEventPublisher，默认线程池为ThreadUtil.newExecutor()

Returns:

SimpleEventPublisher

of

public static SimpleEventPublisher of(List<Subscriber> subscribers)

创建一个默认的SimpleEventPublisher，默认线程池为ThreadUtil.newExecutor()

Parameters:

subscribers - 订阅者列表，也可以传入空列表后调用register(Subscriber)添加

Returns:

SimpleEventPublisher

setExecutorService

public SimpleEventPublisher setExecutorService(ExecutorService executorService)

设置自定义的ExecutorService线程池，默认为ThreadUtil.newExecutor()

Parameters:

executorService - ExecutorService，不能为空

Returns:

this

register

public EventPublisher register(Subscriber subscriber)

Description copied from interface: EventPublisher

注册订阅者，订阅者将接收到所有发布者发布的事件

Specified by:

register in interface EventPublisher

Parameters:

subscriber - 订阅者

Returns:

this

publish

public void publish(Event event)

Description copied from interface: EventPublisher

发布事件，事件发布者将事件发布给所有订阅者

Specified by:

publish in interface EventPublisher

Parameters:

event - 事件对象