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

JUC的理解

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

JUC的理解

 JUC是java.util.concurrent工具包的缩写,是jdk1.5提供的工具包,其中包含了并发操作的多种工具,比如锁、线程池、并发容器和同步工具。

1.锁,JDK1.5在并发包中新增了locks接口和相关实现类(如ReentrantLock),实现了与Synchronized关键字类似的同步功能,需要手动进行上锁和锁的释放。

2.内置的线程池,提供了创建线程池的工具类Executors,可用来创建多种类型的线程池:FixedThreadPool,一池多线程,可用来维护多个线程,使用时直接在线程池中获取;SingleThreadpool,一池一线程,线程池中只维护一个线程;CachedThreadPool,可扩容线程池,可根据具体程序执行需求创建合适数量的线程。

3.线程安全的并发容器,按实现机制可分为三类,第一类降低粒度换取并发性:ConcurrentHashMap;第二类采用写时复制技术,更新数据时不对原集合直接进行操作,而是单独复制一份进行更新,最后把更新后的数据整合到原内容上,实现“并发读,独立写”,保证了线程安全,如:CopyOnWriteArralList类;第三类是lock实现的阻塞队列,内部创建了两个condition实现生产者和消费者的等待。

4.同步工具,借助同步工具的使用也可以保证线程的安全,常用的同步工具有三个:

4.1 Semaphore类代表信号量,可用来控制访问特定资源的线程数;比如:某个地点的停车位(资源)有限,依次只允许3辆车使用

public class SemaphoreDemo {
    public static void main(String[] args) {
        //实例化  设置许可数
        Semaphore semaphore = new Semaphore(3);
        //创建多线程
        for (int i = 1; i <=5 ; i++) {
            new Thread(()->{
                //获取许可
                try {
                    semaphore.acquire();
                    System.out.println(Thread.currentThread().getName()+"抢到车位");
                    //TimeUnit.SECONDS.sleep(new Random().nextInt(5));
                    Thread.sleep(new Random().nextInt(5));
                    System.out.println(Thread.currentThread().getName()+"--------离开了");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }finally {
                    //释放许可
                    semaphore.release();
                }
            },String.valueOf(i)).start();

        }

4.2 CountDownLatch类,减少计数类,一个或多个线程等待其他线程完成操作之后再执行自己的任务;例如:当放学后值班大叔(一个线程)要锁门下班时,需要等待所有同学(每个同学看成一个线程)离开后,才能执行锁门这个操作,然后回家。

//减数计数
public class CountDownLatchDemo {
    public static void main(String[] args) {
       //实例化 设置初始值
        CountDownLatch countDownLatch = new CountDownLatch(5);
        //创建线程
        for (int i = 1; i <= 5; i++) {
            new Thread(()->{
                //线程执行的操作
                System.out.println(Thread.currentThread().getName()+"号同学离开了");
                // 减1
                countDownLatch.countDown();
            },String.valueOf(i)).start();
        }
       // 不为0 等待
        try {
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName()+"锁门了");
    }
}

4.3 CyclicBarrier循环栅栏类,设置一组线程再运行时未满足某个条件时阻塞,等到最后一个线程到来使得条件满足时继续执行。比如:小时候看的动画片里,集齐七颗龙珠可以召唤神龙

public class CyclicBarrierDemo {
    public static void main(String[] args) throws BrokenBarrierException, InterruptedException {
        //实例化  设置限制数  和到达值之后的操做方法
        CyclicBarrier cyclic = new CyclicBarrier(7, () -> {
            System.out.println("召唤神龙");
        });
        //未到达设定值   加1 等待
        for (int i = 1; i <=7 ; i++) {
            new Thread(()->{
                System.out.println(Thread.currentThread().getName()+"号龙珠找到了");
                try {
                    cyclic.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            },String.valueOf(i)).start();

        }

    }
}

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

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

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