长沙做网站哪个最好,朝青板块网站建设,wordpress建双语网站,wordpress与微信小程序目录 多线程相关CountDownLatch赛跑的案例countDownLatch.await(300, TimeUnit.SECONDS); Java其他进阶Map的put方法只放一个元素的集合 多线程相关
CountDownLatch
案例#xff1a;主线程的执行需要等待子线程执行完#xff0c;等各个线程执行完毕后#xff0c;主线程做收… 目录 多线程相关CountDownLatch赛跑的案例countDownLatch.await(300, TimeUnit.SECONDS); Java其他进阶Map的put方法只放一个元素的集合 多线程相关
CountDownLatch
案例主线程的执行需要等待子线程执行完等各个线程执行完毕后主线程做收尾的工作
初始化一个final CountDownLatch latch new CountDownLatch(3);线程池中的子线程调用 countDown方法进行减1主线程启动后等待子线程不断减1直到为0后主线程继续往下执行
package com.tianju.myTest;import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class CountdownLatchTest1 {public static void main(String[] args) {ExecutorService service Executors.newFixedThreadPool(3);final CountDownLatch latch new CountDownLatch(3);for (int i 0; i 3; i) {Runnable runnable new Runnable() {Overridepublic void run() {try {System. out.println(子线程 Thread.currentThread().getName() 开始执行);Thread. sleep((long) (Math. random() * 10000));System. out.println(子线程 Thread.currentThread().getName() 执行完成);latch.countDown(); // 当前线程调用此方法则计数减一} catch (InterruptedException e) {e.printStackTrace();}}};service.execute(runnable);}try {System. out.println(主线程 Thread.currentThread().getName() 等待子线程执行完成... );latch.await(); // 阻塞当前线程直到计时器的值为0System. out.println(主线程 Thread.currentThread().getName() 开始执行...);} catch (InterruptedException e) {e.printStackTrace();}finally {service.shutdown();}}
}赛跑的案例
案例24名选手参加赛跑选手需要等待裁判发送指令裁判发送完指令后需要等所有选手到达终点所有选手到达终点后裁判汇总成绩。
主线程裁判发指令裁判等选手到达终点到达终点后汇总成绩子线程每个选手需要阻塞在裁判发指令之前主线程发指令后子线程继续运行此时主线程阻塞所有子线程结束后主线程继续运行
实现的思路
定义两个CountDownLatch一个为1一个为4CountDownLatch(1)用来控制等待裁判指令主线程先休眠让出资源让子线程获得cpu资源子线程通过await 阻塞主线程休眠结束后对1进行-1然后await 4 阻塞触发子线程子线程继续运行子线程在运行过程中对于4 进行-1等到值为0时触发主线程的await 4 阻塞主线程继续运行裁判进行成绩的汇总 package com.tianju.myTest;import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
// https://www.cnblogs.com/tstd/p/4987935.html
public class CountdownLatchTest2 {public static void main(String[] args) {ExecutorService service Executors.newCachedThreadPool();final CountDownLatch cdOrder new CountDownLatch(1);final CountDownLatch cdAnswer new CountDownLatch(4);for (int i 0; i 4; i) {Runnable runnable new Runnable() {public void run() {try {System.out.println(选手 Thread.currentThread().getName() 正等待裁判发布口令);cdOrder.await(); // 线程都阻塞在这里等待释放System.out.println(选手 Thread.currentThread().getName() 已接受裁判口令);Thread.sleep((long) (Math. random() * 10000));System.out.println(选手 Thread.currentThread().getName() 到达终点);cdAnswer.countDown(); // 进行-1操作4个线程都在操作CountDownLatchSystem.out.println(cdAnswer----:cdAnswer);} catch (Exception e) {e.printStackTrace();}}};service.execute(runnable);}try {Thread. sleep((long) (Math. random() * 10000));System. out.println(裁判 Thread.currentThread ().getName() 即将发布口令 );cdOrder.countDown();System. out.println(裁判 Thread.currentThread ().getName() 已发送口令正在等待所有选手到达终点 );cdAnswer.await();System. out.println(所有选手都到达终点 );System. out.println(裁判 Thread.currentThread ().getName() 汇总成绩排名 );} catch (Exception e) {e.printStackTrace();}service.shutdown();}
}countDownLatch.await(300, TimeUnit.SECONDS);
await方法的对比
没有设置时间会一直阻塞直到countdown为0设置了时间在超过这个时间后解除阻塞返回false 线程一直阻塞的情况 到达时间后就解除阻塞并返回false -1成功返回true Java其他进阶
Map的put方法
Map 的 put 方法其实是有返回值的 package com.tianju.myTest;import java.util.HashMap;
import java.util.concurrent.ConcurrentHashMap;/*** hashMap 的 put 方法其实是有返回值的*/
public class ConHashMap {public static void main(String[] args) {ConcurrentHashMapObject, Object concurrentHashMap new ConcurrentHashMap();// 如果有了键为 pet还能往里面放concurrentHashMap.put(pet, 567);Object put concurrentHashMap.put(pet, task);System.out.println(put);if (put!null){System.out.println( current key used! );}System.out.println(concurrentHashMap);HashMapObject, Object hashMap new HashMap();hashMap.put(pet, 123);Object pet hashMap.put(pet, 561);System.out.println(pet);System.out.println(hashMap);}
}只放一个元素的集合
基于内存或者业务的考虑有时候集合只放一个元素可以用collections下面的singleton集合 package com.tianju.myTest;import java.util.Collections;
import java.util.List;/*** 只能存放一个元素的 List不会造成内存空间的浪费*/
public class SingletonListTest {public static void main(String[] args) {String s hello, singleton;ListString list Collections.singletonList(s);list.add(second element);}
}
