Cczzzz opened a new issue, #8540:
URL: https://github.com/apache/rocketmq/issues/8540
### Is Your Feature Request Related to a Problem?
optimization GroupTransferService Thread
CommitLog#1189
`
public void wakeupCustomer(final PutMessageStatus putMessageStatus) {
this.flushOKFuture.complete(putMessageStatus);
}
`
complete method will use current thread execute "thenCombine" or "thenAccept"
We should reduce GroupTransferService Thread in other places
operatio，because GroupTransferService is single thread
### Describe the Solution You'd Like
use completeAsync
`
this.flushOKFuture.completeAsync(() -> putMessageStatus,
COMMIT_LOG_THREAD_FUTURE_EXECUTOR);
`
COMMIT_LOG_THREAD_FUTURE_EXECUTOR is Custom thread pools ， or use
ForkJoinPool
### Describe Alternatives You've Considered
not
### Additional Context
_No response_
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
