标签：20190619 James 呕心沥血 private 任务 线程 lock new ExecutorService
线程池
线程池的核心接口是ExecutorService。java.util.concurrent还提供了一个静态工厂类Executors，其中包含用于创建配置线程池的工厂方法。
其实 静态工厂方法如下
| 工厂方法 | 描述 |
|---|---|
| newSingleThreadExecutor | 只返回ExecutorService一个线程。 |
| newFixedThreadPool | 返回ExecutorService对象，该对象且持有固定数量的线程。 |
| newCachedThreadPool | 返回ExecutorService对象，该对象持有不同大小的线程池。 |
| newSingleThreadScheduledExecutor | 返回ScheduledExecutorService对象，只返回1个线程 。 |
| newScheduledThreadPool | 返回一个ScheduledExecutorService核心线程集。 |
| newWorkStealingPool | 返回ExecutorService`对象，拥有多个任务队列（以便减少连接数）的线程池。 |
注意：
《Android学习笔记总结+最新移动架构视频+大厂安卓面试真题+项目实战源码讲义》
【docs.qq.com/doc/DSkNLaERkbnFoS0ZF】 完整内容开源分享
调整线程池大小时，大小是根据你的计算机中的逻辑核心数而定的。这个大小可以通过调用
Runtime.getRuntime().availableProcessors()方法获得该值。
| 线程池实现 | 描述 |
|---|---|
| ThreadPoolExecutor | 线程池大小可调整，ThreadPoolExecutor实现了ExecutorService接口，使用池里的线程来执行你提交的任务，通常使用 Executors 工厂方法来配置。 |
| ScheduledThreadPoolExecutor | ThreadPoolExecutor的扩展，并提供了执行定期任务的功能。 |
| ForkJoinPool | ForkJoinPool实现了ExecutorService接口，ForkJoinPool 采用分治思想将大任务分割成几个小任务，小任务继续分割成更小的任务，直至任务不可分割，然后运行这些任务。 |
任务随着ExecutorService#submit，ExecutorService#invokeAll或者提交，ExecutorService#invokeAny对于不同类型的任务具有多个重载。
其实 功能接口如下
| 接口 | 描述 |
|---|---|
| Runnable | run()方法没有返回值。 |
| Callable | call方法有返回值。 |
Future
Future是对于具体的Runnable任务或Callable任务的执行结果进行取消、查询是否完成、获取结果。必要时可以通过get方法获取执行结果，该方法会阻塞直到任务返回结果。
ExecutorService使用Future作为返回类型。
ExecutorService executorService = Executors.newSingleThreadExecutor();
Future future = executorService.submit(() -> “结果”);
try {
String result = future.get(1L, TimeUnit.SECONDS);
System.out.println(“结果为 '” + result + “’.”);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new RuntimeException(e);
} catch (ExecutionException e) {
throw new RuntimeException(e.getCause());
} catch (TimeoutException e) {
throw new RuntimeException(e);
}
assert future.isDone();
ReentrantLock锁
该java.util.concurrent.locks软件包括了经常使用到的Lock接口。ReentrantLock类其实也实现了synchronized关键字的功能，还提供了其它功能，例如获取有关锁的状态，非阻塞tryLock()和可中断锁的信息。使用显式ReentrantLock的示例如下：
class JamesCounter {
private final Lock lock = new ReentrantLock();
private int value;
int increment() {
lock.lock();
try {
return ++value;
} finally {
lock.unlock();
}
}
}
ReadWriteLock读写锁
java.util.concurrent.locks还包含一个ReadWriteLock接口（ReentrantReadWriteLock实现），读写锁，通常允许多个并发读取，但只允许一个写入。
class JamesStatistic {
private final ReadWriteLock lock = new ReentrantReadWriteLock();
private int value;
void increment() {
lock.writeLock().lock();
try {
value++;
} finally {
lock.writeLock().unlock();
}
}
int current() {
lock.readLock().lock();
try {
return value;
} finally {
lock.readLock().unlock();
}
}
}
CountDownLatch工具
CountDownLatch主要用过计数，比如开项目大会，项目经理在会议室门口，有5个程序员A B C D E（相当于5个线程）分别来会议室开会，项目经理手写拿了一份会议人员名单，程序员A进入了会议室后，项目经理把A名单打个勾表示来了（相当于创建了线程A），B进会议室后，在名单上把B也打勾（相当于创建了线程B），但请注意，人没到齐， A,B程序员只能在座位上等待（线程全在等待阻塞中），还不能开会，等5个程序员都到齐了，才开会（5个线程同时被唤醒，开始工作）。
@SpringBootTest(classes = TripApplication.class)
@RunWith(SpringJUnit4ClassRunner.class)
public class JamesTestInvokeRemote {
private static final int THREADS = 200; //200线程模拟用户提交并发
RestTemplate rest = new RestTemplate();
private final String url = “http://127.0.0.1:8090/buyTicket?idcard=123456”;
private static CountDownLatch cdl = new CountDownLatch(THREADS);//200
标签：20190619,James,呕心沥血,private,任务,线程,lock,new,ExecutorService 来源： https://blog.csdn.net/m0_64314432/article/details/122152717
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。