聊城网站营销信息,做金融类网站,wordpress随机广告,没网站怎么做淘宝客文章目录 什么是JUC#xff1f;Callable接口ReentrantLockReentrantLock VS synchronized 原子类线程池信号量SemaphoreCountDownLatch 什么是JUC#xff1f;
JUC是#xff1a;java.util.concurrent这个包名的缩写。它里面包含了与并发相关#xff0c;即与多线程相关的很多… 文章目录 什么是JUCCallable接口ReentrantLockReentrantLock VS synchronized 原子类线程池信号量SemaphoreCountDownLatch 什么是JUC
JUC是java.util.concurrent这个包名的缩写。它里面包含了与并发相关即与多线程相关的很多东西。我们下面就来介绍这些东西。
Callable接口
Callable接口类似与Runnable接口 Runnable接口描述的任务是不带返回值的。 callable接口描述的任务是带返回值的存在的意义就是让我们获取到结果 让我们通过下面的代码来仔细体会一下不同 // 使用Runnable来计算 12.....1000static class Result{public int sum;public Object locker new Object();}public static void main(String[] args) {Result result new Result();//创建一个专门的线程来求和Thread thread new Thread(){Overridepublic void run() {for (int i 0; i 1000; i){result.sum ;}synchronized (result.locker){result.locker.notify();}}};thread.start();// 必须得等thread线程执行完了再打印synchronized (result.locker) {if (result.sum 0){try {result.locker.wait();} catch (InterruptedException e) {e.printStackTrace();}}System.out.println(result.sum);}}// 使用callable来计算12....1000public static void main(String[] args) {//使用callable来定义一个任务CallableInteger callable new CallableInteger() {Overridepublic Integer call() throws Exception {int sum 0;for (int i 0; i 1000; i){sum;}return sum;}};// 用来接受callable任务作为参数FutureTaskInteger futureTask new FutureTask(callable);//Thread 里的参数没有callable类型 只有futuretask类型 所以需要创建一个futuretask类型来过渡Thread thread new Thread(futureTask);thread.start();try {System.out.println(futureTask.get());} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}}ReentrantLock
ReentrantLock也是可重入锁。它的出现是为了补充synchronized可重入锁无法实现的一些操作。
它一共有三个核心的方法
tryLock试试能不能加上锁试成功了就加上锁试失败了就放弃。还可以指定加锁的等待超时时间超过时间则放弃加锁。lock加锁unlock解锁
ReentrantLock VS synchronized
ReentrantLock必须手动调用lock和unlock方法这样如果它们之间出现异常unlock方法就有可能调用不到造成资源浪费。而synchronized则没有这个问题。 public static void main(String[] args) {// 和synchronized相比有三个优势 两个不同ReentrantLock reentrantLock new ReentrantLock();try {reentrantLock.lock();}finally {//当在 lock和unlock 之间出现异常时 unlock就无法执行到 需要用到finally来必须执行//synchronized不存在这个问题 因为它只要出了代码块就一定会解锁reentrantLock.unlock();}}ReentrantLock是标准库的一个类底层是基于Java实现的synchronized是Java关键字底层是通过JVM实现的C实现的tryLock可以尝试加锁并且指定加锁的等待超时时间synchronized会一直死等。在实际开发中往往不使用死等。ReentrantLock可以实现公平锁通过指定构造方法里的一个参数synchronized是非公平锁。 ReentrantLock reentrantLock new ReentrantLock(true);ReentrantLock是搭配Condition类实现通知唤醒操作的唤醒操作可以指定唤醒哪一个线程synchronized是搭配wait-notify实现通知唤醒操作的唤醒操作是随机唤醒一个线程。
原子类
原子类的底层是基于CAS实现的使用原子类最常见的场景就是多线程计数。 CAS操作前面已经非常详细的介绍过点击此处可以查看浏览 //原子类 多用于计数//count.getAndIncrement count//count.incrementAndGer count//count.getAndDecrement count--//count.decrementAndGer --countpublic static void main(String[] args) {AtomicInteger count new AtomicInteger();Thread thread new Thread(() - {for (int i 0; i 50000; i){//相当与count;count.getAndIncrement();}});Thread thread1 new Thread(() - {for (int i 0; i 50000; i){//相当于count;count.getAndIncrement();}});thread.start();thread1.start();try {thread.join();thread1.join();} catch (InterruptedException e) {e.printStackTrace();}System.out.println(count.get());}线程池
前面已经非常详细的介绍过点击此处可以查看浏览
信号量Semaphore
信号量的基本操作有两个 P操作申请一个资源 V操作释放一个资源
信号量本身是一个计数器表示可用资源的个数 P操作申请一个资源可用资源的个数就-1 V操作释放一个资源可用资源的个数就1 当计数为0时继续进行P操作就会阻塞直到其他线程执行V操作释放资源 // 信号量可以看成更广义的锁 锁就是一个信号量 可用资源数只有1public static void main(String[] args) throws InterruptedException {// 需要指定初始值 表示可用资源的个数Semaphore semaphore new Semaphore(4);semaphore.acquire();System.out.println(申请资源);semaphore.acquire();System.out.println(申请资源);semaphore.acquire();System.out.println(申请资源);semaphore.release();System.out.println(释放资源);semaphore.release();System.out.println(释放资源);}CountDownLatch
CountDownLatch使用的效果类似于一个跑步比赛当最后一个选手到达终点就结束。 使用CountDownLatch的时候首先要设置一下有几个选手参赛每个选手撞线了就调用一下countDown方法当撞线次数达到选手的个数时比赛就结束。
放到程序中理解 比如要下载一个很大的文件把文件分成多部分分别下载。使用多线程执行下载任务每个线程下载一部分当所有的线程都下载完毕整个线程就下载完毕了。 //CountDownLatchpublic static void main(String[] args) {// 设置任务的个数CountDownLatch downLatch new CountDownLatch(10);for (int i 0; i 10; i){Thread thread new Thread(() - {System.out.println(开始任务 Thread.currentThread().getName());try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(任务结束 Thread.currentThread().getName());downLatch.countDown();});thread.start();}try {downLatch.await();} catch (InterruptedException e) {e.printStackTrace();}System.out.println(全部任务都结束);}
