在java项目中使用线程池实现并发编程
今天就跟大家聊聊有关在java项目中使用线程池实现并发编程，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。
一、任务和执行策略之间的隐性耦合
Executor可以将任务的提交和任务的执行策略解耦
只有任务是同类型的且执行时间差别不大，才能发挥最大性能，否则，如将一些耗时长的任务和耗时短的任务放在一个线程池，除非线程池很大，否则会造成死锁等问题
1.线程饥饿死锁
类似于：将两个任务提交给一个单线程池，且两个任务之间相互依赖，一个任务等待另一个任务，则会发生死锁；表现为池不够
定义：某个任务必须等待池中其他任务的运行结果，有可能发生饥饿死锁
2.线程池大小
注意：线程池的大小还受其他的限制，如其他资源池：数据库连接池
如果每个任务都是一个连接，那么线程池的大小就受制于数据库连接池的大小
3.配置ThreadPoolExecutor线程池
实例：
通过Executors的工厂方法返回默认的一些实现
通过实例化ThreadPoolExecutor（.....）自定义实现
线程池的队列
1.无界队列：任务到达，线程池饱满，则任务在队列中等待，如果任务无限达到，则队列会无限扩张
如：单例和固定大小的线程池用的就是此种
2.有界队列：如果新任务到达，队列满则使用饱和策略
3.同步移交：如果线程池很大，将任务放入队列后在移交就会产生延时，如果任务生产者很快也会导致任务排队
SynchronousQueue直接将任务移交给工作线程
机制：将一个任务放入，必须有一个线程等待接受，如果没有，则新增线程，如果线程饱和，则拒绝任务
如：CacheThreadPool就是使用的这种策略
饱和策略：
setRejectedExecutionHandler来修改饱和策略
终止Abort（默认）：抛出异常由调用者处理
抛弃Discard
抛弃DiscardOldest：抛弃最旧的任务，注意：如果是优先级队列将抛弃优先级最高的任务
CallerRuns：回退任务，有调用者线程自行处理
4.线程工厂ThreadFactoy
每当创建线程时：其实是调用了线程工厂来完成
自定义线程工厂：implements ThreadFactory
可以定制该线程工厂的行为：如UncaughtExceptionHandler等
public class MyAppThread extends Thread { public static final String DEFAULT_NAME = "MyAppThread"; private static volatile boolean debugLifecycle = false; private static final AtomicInteger created = new AtomicInteger(); private static final AtomicInteger alive = new AtomicInteger(); private static final Logger log = Logger.getAnonymousLogger(); public MyAppThread(Runnable r) { this(r, DEFAULT_NAME); } public MyAppThread(Runnable runnable, String name) { super(runnable, name + "-" + created.incrementAndGet()); //设置该线程工厂创建的线程的 未捕获异常的行为 setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() { public void uncaughtException(Thread t, Throwable e) { log.log(Level.SEVERE, "UNCAUGHT in thread " + t.getName(), e); } }); } public void run() { // Copy debug flag to ensure consistent value throughout. boolean debug = debugLifecycle; if (debug) log.log(Level.FINE, "Created " + getName()); try { alive.incrementAndGet(); super.run(); } finally { alive.decrementAndGet(); if (debug) log.log(Level.FINE, "Exiting " + getName()); } } public static int getThreadsCreated() { return created.get(); } public static int getThreadsAlive() { return alive.get(); } public static boolean getDebug() { return debugLifecycle; } public static void setDebug(boolean b) { debugLifecycle = b; }}免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
在java项目中使用线程池实现并发编程
下载Word文档到电脑，方便收藏和打印～
