public void submit(final String selectorId, final List<Upstream> upstreamList) {
        List<Upstream> validUpstreamList = upstreamList.stream().filter(Upstream::isStatus).collect(Collectors.toList());
        List<Upstream> existUpstream = MapUtils.computeIfAbsent(UPSTREAM_MAP, selectorId, k -> Lists.newArrayList());
        existUpstream.stream().filter(upstream -> !validUpstreamList.contains(upstream))
                .forEach(upstream -> task.triggerRemoveOne(selectorId, upstream));
        validUpstreamList.stream().filter(upstream -> !existUpstream.contains(upstream))
                .forEach(upstream -> task.triggerAddOne(selectorId, upstream));
        UPSTREAM_MAP.put(selectorId, validUpstreamList);
    }
@Test
    @Order(2)
    public void submitTest() {
        final UpstreamCacheManager upstreamCacheManager = UpstreamCacheManager.getInstance();
        List<Upstream> upstreamList = new ArrayList<>(2);
        upstreamCacheManager.submit(SELECTOR_ID, upstreamList);
        upstreamList.add(Upstream.builder().url("url").status(true).build());
        upstreamList.add(Upstream.builder().status(true).build());
        upstreamCacheManager.submit(SELECTOR_ID, upstreamList);
        // hit `existUpstream.stream().filter`
        upstreamList.clear();
        upstreamList.add(Upstream.builder().url("url2").status(true).build());
        upstreamList.add(Upstream.builder().url("url").status(true).build());
        upstreamCacheManager.submit(SELECTOR_ID, upstreamList);
    }