java的线程池

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java的线程池，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2146字，纯文字阅读大概需要4分钟。

内容图文

java的线程池

由于线程和数据库连接这些资源都是非常宝贵的的资源，每次需要的时候创建，不需要的时候销毁，是非常消耗资源的。为在java在java.util.concurrent包下为我们提供了线程池供我们使用。

java线程池的顶级接口是Executor，如下实现图

常采用Executors来创建线程池，其中最常用如下：

public class Executors {


    /**
     * 创建一个根据需要创建新线程的线程池,当调用execute将重用以前构造出来的线程，
     * 如果现有的线程没有可用的,将会重新创建新的线程，并添加到线程池中，
     *如果线程在60s没有被使用，将会从线程池中移除。如果长时间保持空闲，该线程池不会占用任何资源
     *
     * @return the newly created thread pool
     */
    public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>());
    }
    
    /**
     * 创建固定数量线程的线程池，如果线程池中没有足够的数量的线程来执行任务，
     * 则任务将会在队列中等待，直到有线程来执行它。除非线程被显示的关闭，否则线程池中的线程将会一直存在
     *
     * @param nThreads the number of threads in the pool
     * @param threadFactory the factory to use when creating new threads
     * @return the newly created thread pool
     * @throws NullPointerException if threadFactory is null
     * @throws IllegalArgumentException if {@code nThreads <= 0}
     */
    public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue<Runnable>(),
                                      threadFactory);
    }
    
    /**
     * 创建一个线程池，可以安排在给定延迟命令或者定期地执行
     * @param corePoolSize the number of threads to keep in the pool,
     * even if they are idle
     * @return a newly created scheduled thread pool
     * @throws IllegalArgumentException if {@code corePoolSize < 0}
     */
    public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
        return new ScheduledThreadPoolExecutor(corePoolSize);
    }
    
    /**
     * 创建一个线程的线程池，当这个线程池中的线程死后，或者发生异常，重新启动一个线程来代替原来的线程
     *
     * @return the newly created single-threaded Executor
     */
    public static ExecutorService newSingleThreadExecutor() {
        return new FinalizableDelegatedExecutorService
            (new ThreadPoolExecutor(1, 1,
                                    0L, TimeUnit.MILLISECONDS,
                                    new LinkedBlockingQueue<Runnable>()));
    }	

}

内容总结

以上是互联网集市为您收集整理的java的线程池全部内容，希望文章能够帮你解决java的线程池所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端