栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

集合和并发

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

集合和并发

HashMap

Collectors.toMap()方法不能传入重复的值

[强制]在使用java.util.stream.Collectors类的toMap0方法转为Map集合时,一定要使用含有参数类型为BinaryOperator ,参数名为mergeFunction的方法,否则当出现相同key值时会抛illeqalStateException异常。

hashMap里面key、value都可以为null,但是merge的时候就不允许了。Colector.toMap()方法会调用merge方法,里面值不允许为null,否则抛出NPE异常。key重复时需要自定义。

ArrayList

ArrayList的subList结果不可强转成ArrayList。

所以ArrayList的subList()返回的是ArrayList的内部类SubList,强转成ArrayList,则会抛出ClassCastException异常。

内部类SubList,并不是ArrayList本身,而是ArrayList的一个视图,对于SubList的所有操作最终会反映到原列表上。

并发处理

1、并行:同时处理多任务的能力。

2、并发:是指在某个时间段内, 多任务交替处理的能力。

线程安全

线程安全问题只在多线程环境下才出现,单线程串行执行不存在此问题。

保证高并发场景下的线程安全,可以从以下四个维度考量:

1、数据单线程内可见

2、只读对象

3、线程安全类

4、同步与锁机制

Java中常用锁实现的方式

1、用并发包中的锁类

2、利用同步代码块

AQS的本质:解决多线程访问共享资源并发问题的同步管理框架

state就是AQS(Abstract Queued Synchronizer)里面的核心资源,即抢的资源

为什么要定义Sync来继承AQS?

为了重写锁的实现机制。

AQS为Java并发同步组件提供统一的底层支持,支持有目的、有步骤、有计划的协同作业

AQS的使用场景

1、线程同步类:

Semphore、ReentrantReadWriteLock 、ReentrantLock、CountDownLatch、CyclicBarrier

2.线程池:

ThreadPoolExecutor、ScheduledThreadPoolExecutor

3.线程安全Queue/List/Map:

ConcurrentHashMap、linkedBlockingQueue、CopyOnWriteArrayList

nextWaiter:下一个要唤醒的锁(即条件队列)

一个条件队列,一个等待队列。

为什么要两个队列?

条件队列(Condition queue):有没有资格(免得不符合资格再退出,浪费时间)

等待队列(Sync queue):进入等待区域

AQS里面有公平锁、非公平锁

独占的资源在AOS里面设置的

线程池

线程池的作用包括:

1.利用线程池管理并复用线程、控制最大并发数等

2.增加对线程的管理,快速排查问题

3.实现任务线程队列缓存策略和拒绝机制

4.实现某些与时间相关的功能,如定时执行、周期执行等

5.隔离线程环境

比如,交易服务和搜索服务在同一台服务器上,分别开启两个线程池,交易线程的资源消耗明显要大;因此,通过配置独立的线程池,将较慢的交易服务与搜索服务隔离开,避免各服务线程相互影响。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/489564.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号