@Override
    public void executor(final Collection<MetaDataRegisterDTO> metaDataRegisterDTOList) {
        metaDataRegisterDTOList.forEach(meta -> Optional.ofNullable(this.shenyuClientRegisterService.get(meta.getRpcType()))
                .ifPresent(shenyuClientRegisterService -> {
                    synchronized (shenyuClientRegisterService) {
                        shenyuClientRegisterService.register(meta);
                    }
                }));
    }
@Test
    public void testExecutor() {
        List<MetaDataRegisterDTO> list = new ArrayList<>();
        metadataExecutorSubscriber.executor(list);
        Assertions.assertTrue(list.isEmpty());
        list.add(MetaDataRegisterDTO.builder().appName("test").build());
        ShenyuClientRegisterService service = mock(ShenyuClientRegisterService.class);
        when(shenyuClientRegisterService.get(any())).thenReturn(service);
        metadataExecutorSubscriber.executor(list);
        verify(service).register(any());
    }