src/main/java/com/alipay/remoting/rpc/protocol/RpcCommandHandler.java
private void handle(final RemotingContext ctx, final Object msg) {
        try {
            if (msg instanceof List) {
                final Runnable handleTask = new Runnable() {
                    @Override
                    public void run() {
                        if (logger.isDebugEnabled()) {
                            logger.debug("Batch message! size={}", ((List<?>) msg).size());
                        }
                        for (final Object m : (List<?>) msg) {
                            RpcCommandHandler.this.process(ctx, m);
                        }
                    }
                };
                if (RpcConfigManager.dispatch_msg_list_in_default_executor()) {
                    // If msg is list ,then the batch submission to biz threadpool can save io thread.
                    // See com.alipay.remoting.decoder.ProtocolDecoder
                    processorManager.getDefaultExecutor().execute(handleTask);
                } else {
                    handleTask.run();
                }
            } else {
                process(ctx, msg);
            }
        } catch (final Throwable t) {
            processException(ctx, msg, t);
        }
    }
private void handle(final RemotingContext ctx, final Object msg) {
        try {
            if (msg instanceof List) {
                final Runnable handleTask = new Runnable() {
                    @Override
                    public void run() {
                        if (logger.isDebugEnabled()) {
                            logger.debug("Batch message! size={}", ((List<?>) msg).size());
                        }
                        for (final Object m : (List<?>) msg) {
                            RpcCommandHandler.this.process(ctx, m);
                        }
                    }
                };
                if (RpcConfigManager.dispatch_msg_list_in_default_executor()) {
                    // If msg is list ,then the batch submission to biz threadpool can save io thread.
                    // See com.alipay.remoting.decoder.ProtocolDecoder
                    processorManager.getDefaultExecutor().execute(handleTask);
                } else {
                    handleTask.run();
                }
            } else {
                process(ctx, msg);
            }
        } catch (final Throwable t) {
            processException(ctx, msg, t);
        }
    }
private void handle ( final RemotingContext ctx , final Object msg ) { try { if ( msg instanceof List ) { final Runnable handleTask = new Runnable ( ) { @ Override public void run ( ) { if ( logger . isDebugEnabled ( ) ) { logger . debug ( "Batch message! size={}" , ( ( List < ? > ) msg ) . size ( ) ) ; } for ( final Object m : ( List < ? > ) msg ) { RpcCommandHandler . this . process ( ctx , m ) ; } } } ; if ( RpcConfigManager . dispatch_msg_list_in_default_executor ( ) ) { // If msg is list ,then the batch submission to biz threadpool can save io thread. // See com.alipay.remoting.decoder.ProtocolDecoder processorManager . getDefaultExecutor ( ) . execute ( handleTask ) ; } else { handleTask . run ( ) ; } } else { process ( ctx , msg ) ; } } catch ( final Throwable t ) { processException ( ctx , msg , t ) ; } }
/*
Handle the request(s).
/ * Handle the request ( s ) .