java并发编程学习之线程池-预定义线程池(四)

suemi 发布于2019-08-19 10:16 / 1028人阅读

摘要：系统预定了几个线程池，不过建议手动创建，以防止错误创建消耗资源，比如创建太多线程或者固定线程数量，无界队列固定线程数量，数量为，无界队列，会按顺序执行不限制线程数量，使用队列，使用于短任务基于用于周期性执行任务示例第一个是，第二个是第一

系统预定了几个线程池，不过建议手动创建，以防止错误创建消耗资源，比如创建太多线程或者OOM

FixedThreadPool

固定线程数量，无界队列

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue());
}

SingleThreadExecutor

固定线程数量，数量为1，无界队列，会按顺序执行

public static ExecutorService newSingleThreadExecutor() {
    return new FinalizableDelegatedExecutorService
        (new ThreadPoolExecutor(1, 1,
                                0L, TimeUnit.MILLISECONDS,
                                new LinkedBlockingQueue()));
}

CachedThreadPool

不限制线程数量，使用SynchronousQueue队列，使用于短任务

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue());
}

WorkStealingPool

基于ForkJoinPool

public static ExecutorService newWorkStealingPool(int parallelism) {
    return new ForkJoinPool
        (parallelism,
         ForkJoinPool.defaultForkJoinWorkerThreadFactory,
         null, true);
}

ScheduledThreadPoolExecutor

用于周期性执行任务

public static ScheduledExecutorService newSingleThreadScheduledExecutor() {
    return new DelegatedScheduledExecutorService
        (new ScheduledThreadPoolExecutor(1));
}

示例

public class ScheduledDemo {
    static class Thread1 implements Runnable {
        @Override
        public void run() {
            SimpleDateFormat formater = new SimpleDateFormat(
                    "yyyy-MM-dd HH:mm:ss");
            System.out.println(Thread.currentThread().getName() + ":" + formater.format(new Date()));
        }
    }

    public static void main(String[] args) {
        ScheduledThreadPoolExecutor schedule
                = new ScheduledThreadPoolExecutor(1);
        //第一个是Runnable，第二个是第一次开始的时间，第三个是周期时间，第四个是时间单位
        schedule.scheduleAtFixedRate(new Thread1(),1000,1000, TimeUnit.MILLISECONDS);
    }
}

运行结果如下：

云服务器 GPU云服务器 java线程池并发线程池并发 linux线程池并发服务器并发线程池

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/75723.html

java并发编程学习之线程池-ThreadPoolExecutor(三)

摘要：是所有线程池实现的父类，我们先看看构造函数构造参数线程核心数最大线程数线程空闲后，存活的时间，只有线程数大于的时候生效存活时间的单位任务的阻塞队列创建线程的工程，给线程起名字当线程池满了，选择新加入的任务应该使用什么策略，比如抛异常丢弃当前 ThreadPoolExecutor ThreadPoolExecutor是所有线程池实现的父类，我们先看看构造函数构造参数 corePool...

阿罗 2019-08-19 10:15 评论0 收藏0
java并发编程学习之线程池-Executor和ExecutorService(一)

摘要：接口用于提交任务接口继承了接口设置线程的状态，还没执行的线程会被中断设置线程的状态，尝试停止正在进行的线程当调用或方法后返回为当调用方法后，并且所有提交的任务完成后返回为当调用方法后，成功停止后返回为当前线程阻塞，直到线程执行完时间到被中断 Executor接口 void execute(Runnable command)//用于提交command任务 ExecutorService接...

liuchengxu 2019-08-19 10:15 评论0 收藏0
java并发编程学习之线程池-AbstractExecutorService(二)

摘要：抽象类，实现了的接口。将任务封装成提交任务主要方法在任务是否超时超时时间任务书用于存放结果的，先完成的放前面。 AbstractExecutorService抽象类，实现了ExecutorService的接口。 newTaskFor 将任务封装成FutureTask protected RunnableFuture newTaskFor(Runnable runnable, T va...

Jokcy 2019-08-19 10:16 评论0 收藏0
java并发编程学习之线程的生命周期-join(四）

摘要：定义等待该线程终止，比如线程调用了线程的，那么线程要等到线程执行完后，才可以继续执行。定义等待该线程终止，比如A线程调用了B线程的join，那么A线程要等到B线程执行完后，才可以继续执行。示例 public class JoinDemo { static class JoinThread1 implements Runnable { Thread thre...

xavier 2019-08-16 18:30 评论0 收藏0
一起学并发编程 - 简易线程池实现

摘要：并且，线程池在某些情况下还能动态调整工作线程的数量，以平衡资源消耗和工作效率。同时线程池还提供了对池中工作线程进行统一的管理的相关方法。开发中经常会遇到各种池（如：连接池，线程池），它们的作用就是为了提高性能及减少开销，在JDK1.5以后的java.util.concurrent包中内置了很多不同使用场景的线程池，为了更好的理解它们，自己手写一个线程池，加深印象。概述 1.什么是...

Harriet666 2019-08-15 12:09 评论0 收藏0