optimize eventbus process when queue is full

[leizhiyuan]

Your question

com.alipay.sofa.rpc.event.EventBus#post

/**
     * 给事件总线中丢一个事件
     *
     * @param event 事件
     */
    public static void post(final Event event) {
        if (!isEnable()) {
            return;
        }
        CopyOnWriteArraySet<Subscriber> subscribers = SUBSCRIBER_MAP.get(event.getClass());
        if (CommonUtils.isNotEmpty(subscribers)) {
            for (final Subscriber subscriber : subscribers) {
                if (subscriber.isSync()) {
                    handleEvent(subscriber, event);
                } else { // 异步
                    final RpcInternalContext context = RpcInternalContext.peekContext();
                    AsyncRuntime.getAsyncThreadPool().execute(
                        new Runnable() {
                            @Override
                            public void run() {
                                try {
                                    RpcInternalContext.setContext(context);
                                    handleEvent(subscriber, event);
                                } catch (Exception e) {
                                    RpcInternalContext.removeContext();
                                }
                            }
                        });
                }
            }
        }
    }

if AsyncRuntime.getAsyncThreadPool().execute throw an exception because of queue is full, the current thread will break

Your scenes

maybe we need to catch this exception . subscriber which is async need to accept the lost of event.

Your advice

describe the advice or solution you'd like

Environment

• SOFARPC version:
• JVM version (e.g. java -version):
• OS version (e.g. uname -a):
• Maven version:
• IDE version: