Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

About process a batch of messages #467

Open
laulee5135 opened this issue Dec 12, 2023 · 4 comments
Open

About process a batch of messages #467

laulee5135 opened this issue Dec 12, 2023 · 4 comments

Comments

@laulee5135
Copy link

In version 4.x, is there a successor to Disruptor::handleEventsWithWorkerPool? Can multiple consumers cooperate to process a batch of messages? (one message will only be processed by one consumer)

@Palmr
Copy link
Contributor

Palmr commented Dec 13, 2023

As mentioned in #323 the reason we removed the code in v4 was mostly down to us not using it, making it quite a burden to maintain.

There are not really any changes inherent in v4 that make that code incompatible, so with some copy & paste the code could be copied from the Disruptor v3 DSL and into your project with relative ease.

@tcmot
Copy link

tcmot commented Dec 14, 2023

As mentioned in #323 the reason we removed the code in v4 was mostly down to us not using it, making it quite a burden to maintain.

There are not really any changes inherent in v4 that make that code incompatible, so with some copy & paste the code could be copied from the Disruptor v3 DSL and into your project with relative ease.

Yes,copy many classes, classes and fields are not public.
I think,it need an extension mechanism.

ConsumerInfo
ConsumerRepository
Disruptor
EventHandlerGroup
EventProcessorInfo
EventReleaseAware
EventReleaser
LifecycleAware
TimeoutHandler
WorkerPool
WorkerPoolInfo
WorkHandler
WorkProcessor

@Palmr

@tcmot
Copy link

tcmot commented Dec 19, 2023

https://github.com/tcmot/Disruptor2

This is a demo, disruptor4.0+WorkerPool.

@enddeadroyal
Copy link

you can design the strategy handler + event handler to implement the work pool handler

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

4 participants