线程池的创建与使用

news2024/12/31 3:26:31

void execute(Runnable run)方法处理Runnbale任务
Future<> submit(Callable<> task)方法处理Callable任务
void shutdown()结束线程池
List<\Runnable> shutdownNow()立即结束线程池，不管任务是否执行完毕

//创建线程池的一种方式
ExecutorService pool = new ThreadPoolExecutor(2,5,1,
                TimeUnit.HOURS,new ArrayBlockingQueue<>(2),
                Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());
 //构造器（核心线程数量，最大线程数量，临时线程的存活时长，
 //临时线程的存活时间单位，等待任务队列，线程池工厂，任务拒绝策略）
 //任务等待队列常用：new ArrayBlockingQueue<>(等待任务数量)，new LinkedBlockingQueue<>()没有数量限制
 //new ThreadPoolExecutor.AbortPolicy()当线程在忙，任务队列也满了，新任务来了会抛出异常

Runnable target = new MyRunnable();
//execute()方法处理Runnbale任务
//创建线程任务
pool.execute(target);
//线程池分配线程执行任务
pool.execute(target);
//2个核心线程都在忙，若新任务来则创建临时线程
pool.execute(target);
pool.execute(target);
pool.execute(target);
//三个临时线程也在忙，若新任务来则加入任务队列
pool.execute(target);
pool.execute(target);
//任务队列已满，若新任务来则拒绝并抛出异常
pool.execute(target);
//拒绝新任务，并抛出异常

Future<String> f1 = pool.submit(new CallableThread(100));
        //调用submit()方法处理Callable任务对象，返回Future对象
        Future<String> f2 = pool.submit(new CallableThread(200));
        Future<String> f3 = pool.submit(new CallableThread(300));
        Future<String> f4 = pool.submit(new CallableThread(400));
        f1.get();
        //调用返回的Future对象的get()方法获得任务的返回结果
        f2.get();
        f3.get();
        f4.get();