　　接口太慢，其中一种方式就是使用多线程进行快速处理。

　　介绍下，如何在项目中写代码的。

　　这里在for循环里使用调用，不是好方式，碍于接口只支持单个节点的查询。

    private List<DeviceInfo> getDeviceByEmissionNoList(Long customerId, List<String> emissionSourceNoList) {
        List<DeviceInfo> deviceNoList = Lists.newArrayList();
        CountDownLatch countDownLatch = new CountDownLatch(emissionSourceNoList.size());
        for (String emissionSourceNo : emissionSourceNoList) {
            executor.submit(() -> {
                try {
                    NodeInfo<Object, Object> nodeInfo = emissionSourceServiceFeign.queryDownVertex(DtoConvert.buildEmissionSourceVertexInfo(customerId, emissionSourceNo));
                    if (Objects.nonNull(nodeInfo)) {
                        List<VertexInfo<Object>> nodes = nodeInfo.getNodes();
                        if (!CollectionUtils.isEmpty(nodes)) {
                            nodes.forEach(node -> {
                                if (Objects.equals(VertexLabelConstants.MONITOR, node.getLabel()) || Objects.equals(VertexLabelConstants.GOVERN, node.getLabel())) {
                                    LinkedHashMap deviceInfoMap = (LinkedHashMap) node.getNode();
                                    if (Objects.nonNull(deviceInfoMap)) {
                                        DeviceInfo deviceInfo = (DeviceInfo) MetaClassUtil.mapToObj(deviceInfoMap, DeviceInfo.class);
                                        deviceInfo.setLabel(node.getLabel());
                                        deviceNoList.add(deviceInfo);
                                    }
                                }

                            });
                        }
                    }
                } finally {
                    countDownLatch.countDown();
                }
            });
        }
        try {
            countDownLatch.await();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return deviceNoList;
    }