public static void startInvoke()

in src/frontend/src/main/java/com/alibabacloud/hipstershop/web/RouterTestController.java [123:182]
55 lines of code
9 McCabe index (conditional complexity)

    public static void startInvoke(String port) {
        INVOKER_ENABLE.set(true);

        EXECUTOR_SERVICE.submit((Runnable) () -> {
            while (INVOKER_ENABLE.get()) {
                try {
                    TimeUnit.MILLISECONDS.sleep(10);
                    DUBBO_INVOKER_TIMES.getAndIncrement();
                    HttpUriRequest request = new HttpGet(
                            "http://127.0.0.1:" + port + "/router/dubbo?name=" + dubbo_name + "&age=" + dubbo_age);
                    CloseableHttpResponse response = HttpClients.createDefault().execute(request);
                    String result = new BufferedReader(new InputStreamReader(response.getEntity().getContent()))
                            .readLine();
                    synchronized (DUBBO_LOCK) {
                        if (INVOKER_ENABLE.get()) {
                            if (result.length() < 20) {
                                DUBBO_RESULT_QUEUE.add(result);
                            } else {
                                DUBBO_RESULT_QUEUE.add("出错了");
                                DUBBO_ERROR_TIMES.getAndIncrement();
                            }
                        }
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }

            }
        });

        EXECUTOR_SERVICE.submit((Runnable) () -> {
            while (INVOKER_ENABLE.get()) {
                try {
                    TimeUnit.MILLISECONDS.sleep(10);
                    SPRING_CLOUD_INVOKER_TIMES.getAndIncrement();
                    HttpUriRequest request = new HttpGet(
                            "http://127.0.0.1:" + port + "/router/springcloud?name=" + spring_cloud_name + "&age="
                                    + spring_cloud_age);
                    CloseableHttpResponse response = HttpClients.createDefault().execute(request);
                    String result = new BufferedReader(new InputStreamReader(response.getEntity().getContent()))
                            .readLine();
                    synchronized (SPRING_CLOUD_LOCK) {
                        if (INVOKER_ENABLE.get()) {
                            if (result.length() < 20) {
                                SPRING_CLOUD_RESULT_QUEUE.add(result);
                            } else {
                                SPRING_CLOUD_RESULT_QUEUE.add("出错了");
                                SPRING_CLOUD_ERROR_TIMES.getAndIncrement();
                            }
                        }
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }

            }
        });

        ROUTER_BEGIN.set(true);
    }