void doRun() throws InterruptedException {
        ExecutorService threadPool = Executors.newFixedThreadPool(THREAD_NUM);
        for (int i = 0; i < THREAD_NUM; i++) {
            Node n = new Node(threadPool);
            threadPool.submit(n);
        }
    }