请选择 进入手机版 | 继续访问电脑版

java并发编程实战6-基础构建模块

[复制链接]
三兄弟沙发谢洪江 发表于 2020-12-31 20:23:05 | 显示全部楼层 |阅读模式 打印 上一主题 下一主题
1、同步容器类
  常见的容器:Vector、HashTable、Collections.synchronizedXXX封装类等
都是线程安全的,但在某些情况下大概需要客户端加锁来掩护复核使用(如A线程获取最后一个值,B线程删除最后一个元素,这两个使用大概交替执行,大概使得抛出ArrayIndexOutOfBoundsException),使效果符合盼望。
迭代器体现形为使“实时失败”(fail-fast),即当迭代过程中容器被其他线程修改时,就抛出ConcurrentModificationException异常,容器内部接纳了计数器与容器关联,迭代期间计数器被修改,那么next就会抛出异常。如果不希望迭代过程中抛出异常,可用的方式加锁大概克隆容器。加锁大概存在线程饥饿或死锁等情况,所以大多数情况下并不推荐。克隆容器就是在线程封闭的副本上迭代,不外在容器克隆时会有显著的性能开销,能否接纳就要看容器巨细、在元素上执行的使用等多个因素
容器在做toString、contianAll、removeAll、hashCode、equal时等使用时也会间接的执行迭代使用,所以也有大概抛出ConcurrentModificationException异常
2、 并发容器
  常见容器:currentHashMap、CopyOnWriteArrayList、ConcurrentLinkedQueue(FIFO)、BlockingQueue等
currentHashMap:使用分段锁(lock
striping)来实现最大水平的数据共享,执行读取和写入的线程可以并发的访问Map。迭代器具有弱一致性并非实时失败,一些需要盘算整个Map的使用如size是一个估计值并非准确值。实现了“没有则添加”、“相等移除”’、“相等替换”等复合原子使用
CopyOnWriteArrayList:发布了事实不可变对象,访问不需要同步。每次修改时,都会创建并重新发布一个新的容器,实现可变性。适用于迭代使用远远多于修改使用。
3、阻塞队列
  阻塞队列提供了可阻塞的put和take方法,并支持定时的offer和poll方法。已满的队列put阻塞至存在空余空间,为空的对了take阻塞至队列不为空
FIFO(先进先出):ConcurrentLinkedQueue、LinkedBlokingQueue
优先级队列:PriorityBlockingQueue
串行线程封闭:使用阻塞队列的内部同步机制,从而安全的将对象从生产者发布到消费者的线程 双端队列与工作密取
4、 阻塞方法与中断方法
  线程阻塞状态:BLOCKED、WAITING、TIMED_WAITING
中断方法:Thread提供了interrupt方法,用于中断或查询是否中断
5、 同步工具类
  闭锁:可以用来确保某些运动直到其他运动都完成才继续执行;CountDownLatch是一种灵活的闭锁实现,闭锁状态包罗了一个计数器,countDown方法递减计数器,await方法等候计数器达到零。
FutureTest:get方法可以盘算并获取任务的执行状态,等候运行、正在运行、执行完成3个状态,是由Callbale方式实现,也可以实现闭锁
信号量(Counting
Semaphore):用来控制访问特定资源的使用数量;可以用来实现某种资源池或容器界限;acquire方法得到许可(已满阻塞),release方法释放许可
栅栏(Barrier):所有线程必须到达栅栏位置才能继续执行大概两方栅栏互换数据
6、 构建高效且可伸缩的效果缓存
  1. public interface Computable {    V compute(A arg) throws InterruptedException;}public class ExpensiveFunction implements Computable {    @Override    public BigInteger compute(String arg) throws InterruptedException {        return new BigInteger(arg);    }}        public class Memoizer implements Computable {    private final ConcurrentHashMap cache = new ConcurrentHashMap();    private final Computable c;    public Memoizer(Computable c) {        this.c = c;    }    @Override    public V compute(final A arg) throws InterruptedException {        while (true) {            Future f = cache.get(arg);            if (f == null) {                Callable eval = new Callable() {                    @Override                    public V call() throws Exception {                        return c.compute(arg);                    }                };                FutureTask ft = new FutureTask(eval);                f = cache.putIfAbsent(arg, ft);                if (f == null) {                    f = ft;                    ft.run();                }            }            try {                return f.get();            }catch (InterruptedException e) {                cache.remove(arg, f);            } catch (ExecutionException e) {                e.printStackTrace();            }        }    }}
复制代码
来源:https://blog.csdn.net/qiuye_liang/article/details/111937168
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

发布主题

专注素材教程免费分享
全国免费热线电话

18768367769

周一至周日9:00-23:00

反馈建议

27428564@qq.com 在线QQ咨询

扫描二维码关注我们

Powered by Discuz! X3.4© 2001-2013 Comsenz Inc.( 蜀ICP备2021001884号-1 )