如何在Java终止Threadpool？[关闭]

Question

public void createThread(){
  for(int i=o  to 100000){
      method();
    }
}

public void method(){

  ExecutersService threadpool = Executers.newFixedThreadPool(1);
 threadpool.execute(new Runnable(){

    void run(){
       print(Thread.currentThread().getName());
   }
   threadpool.shutdown();

 });
  
}

输出:pool-2=线程-1 pool-3=线程-1,pool-4=线程-1.............

我想要池-2=线程-1池-2=线程-1池-2=线程-1................

Threadpool不能从method（）放到外部，每次都需要创建新的Threadpool。我可以完全终止线程池吗？

有什么需要帮忙的吗

Answer 1

如果要使用相同的线程池，要么将其作为变量传递，要么使其成为类的属性

class Test {

    ExecutorService threadpool = Executors.newFixedThreadPool(1);

    public void createThread() {
        for (int i = 0; i < 1000; ++i) {
            method();
        }

        shutdownAndAwaitTermination(threadpool, 5, TimeUnit.MILLISECONDS);
        // or MoreExecutors.shutdownAndAwaitTermination(threadPool, 5,
        // TimeUnit.MILLISECONDS)
    }

    public void method() {
        threadpool.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName());
            }
        });
    }

    // Copied from Guava Library
    public void shutdownAndAwaitTermination(ExecutorService service, long timeout, TimeUnit unit) {
        long halfTimeoutNanos = unit.toNanos(timeout) / 2;
        service.shutdown();
        try {
            if (!service.awaitTermination(halfTimeoutNanos, TimeUnit.NANOSECONDS)) {
                service.shutdownNow();
                service.awaitTermination(halfTimeoutNanos, TimeUnit.NANOSECONDS);
            }
        } catch (InterruptedException ie) {
            Thread.currentThread().interrupt();
            service.shutdownNow();
        }
    }
}