@Override
    public void updateCorePoolSize(int corePoolSize) {
        if (corePoolSize > 0
            && corePoolSize <= Short.MAX_VALUE
            && corePoolSize < this.defaultMQPushConsumer.getConsumeThreadMax()) {
            this.consumeExecutor.setCorePoolSize(corePoolSize);
        }
    }
@Test
    public void testUpdateCorePoolSize() {
        popService.updateCorePoolSize(2);
        popService.incCorePoolSize();
        popService.decCorePoolSize();
        assertEquals(2, popService.getCorePoolSize());
    }