Java使用线程池

package UnitTest;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

@SuppressWarnings("unchecked")
public class test {
    public static void main(String[] args) throws InterruptedException {
        ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10);
        List<Future> resultList = new ArrayList<>();
        for (int i = 1; i < 101; i++) {
            Future future = fixedThreadPool.submit(new ThreadWithRunnable(i));
            resultList.add(future);
        }
        fixedThreadPool.shutdown();
        fixedThreadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);
        System.out.println("所有进程成功结束!");
    }
}

package UnitTest;

import java.util.concurrent.Callable;

public class ThreadWithRunnable implements Callable {
    private int number;
    public ThreadWithRunnable(int number){
        this.number = number;
    }

    @Override
    public Object call() {
        System.out.println("开始线程:"+Thread.currentThread().getName()+"       传入参数："+number);
        return number;
    }
}