Spring Boot整合LMAX Disruptor

public class EventInfoServiceImpl {

    private Disruptor<EventInfoAndBack> applyDisruptor;
    private RingBuffer<EventInfoAndBack> applyQueue;

    @GrpcClient("grpc-server")
    private EventInfoServiceGrpc.EventInfoServiceFutureStub eventInfoServiceFutureStub;

    public EventInfoServiceImpl() {
        ThreadPoolExecutor executor = new ThreadPoolExecutor(7, 7, 1, TimeUnit.SECONDS, new ArrayBlockingQueue<>(1));
        this.applyDisruptor = DisruptorBuilder.newInstance(EventInfoAndBack.class).setRingBufferSize(1024).setEventFactory(new EventInfoFactory()).setExecutor(executor).setProducerType(ProducerType.MULTI).setWaitStrategy(new BlockingWaitStrategy()).build();
        this.applyDisruptor.handleEventsWithWorkerPool(new EventInfoWorkHandler("1"),new EventInfoWorkHandler("2"),new EventInfoWorkHandler("3"));
        this.applyDisruptor.handleEventsWith(new EventInfoHandler("1"), new EventInfoHandler("2"));
        this.applyDisruptor.handleEventsWithWorkerPool(new EventInfoWorkHandler("4"),new EventInfoWorkHandler("5"));
        this.applyDisruptor.setDefaultExceptionHandler(new FatalExceptionHandler());
        applyQueue = applyDisruptor.start();
    }

    public EventInfoResponse sendEventInfoMessage(String data) {
        EventInfoMessage eventInfoMessage = EventInfoMessage.newBuilder().setMsg(data).build();
        AtomicReference<EventInfoResponse> eventInfoResponse = new AtomicReference<>();
        for (int i = 0; i < 10; i++) {
            applyQueue.publishEvent((event, sequence) -> {
                event.eventInfoMessage = eventInfoMessage;
                event.back = eventInfoResponse::set;
            });
        }
        while (eventInfoResponse.get() == null){

        }
        return eventInfoResponse.get();
    }

    private class EventInfoAndBack {
        EventInfoMessage eventInfoMessage;
        Back<EventInfoResponse> back;

        public EventInfoMessage getEventInfoMessage() {
            return eventInfoMessage;
        }

        public void setEventInfoMessage(EventInfoMessage eventInfoMessage) {
            this.eventInfoMessage = eventInfoMessage;
        }

        public Back<EventInfoResponse> getBack() {
            return back;
        }

        public void setBack(Back<EventInfoResponse> back) {
            this.back = back;
        }
    }

    private class EventInfoFactory implements EventFactory<EventInfoAndBack> {
        @Override
        public EventInfoAndBack newInstance() {
            return new EventInfoAndBack();
        }
    }

    private class EventInfoHandler implements EventHandler<EventInfoAndBack> {

        private String str;

        public EventInfoHandler(String str) {
            this.str = str;
        }

        @Override
        public void onEvent(EventInfoAndBack eventInfo, long l, boolean b) throws Exception {
            System.out.println("event-"+str+":"+Thread.currentThread().getName());
            ListenableFuture<EventInfoResponse> response = eventInfoServiceFutureStub.sendMessageEvent(eventInfo.getEventInfoMessage());
            eventInfo.back.run(response.get());
        }
    }

    private class EventInfoWorkHandler implements WorkHandler<EventInfoAndBack> {

        private String str;

        public EventInfoWorkHandler(String str) {
            this.str = str;
        }

        @Override
        public void onEvent(EventInfoAndBack eventInfo) throws Exception {
            System.out.println("work-"+str+":"+Thread.currentThread().getName());
            ListenableFuture<EventInfoResponse> response = eventInfoServiceFutureStub.sendMessageEvent(eventInfo.getEventInfoMessage());
            eventInfo.back.run(response.get());
        }
    }

    private interface Back<T> {
        void run(T t);
    }

}