Java|Java guava monitor监视器线程的使用详解 Javaguavamonitor监视器线程的使用

Maven依赖

com.google.guavaguava31.0.1-jre

代码不废话上代码。

package com.huyi.csdn.tools; import cn.hutool.core.thread.ThreadUtil; import com.google.common.util.concurrent.Monitor; import org.springframework.scheduling.concurrent.CustomizableThreadFactory; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.function.Function; /** * @Program: csdn @ClassName: MonitorRunner @Author: huyi @Date: 2021-10-30 15:22 @Description: * 监视器Runner @Version: V1.0 */public class MonitorRunner implements Runnable {private T param; private Function condition; private Runnable runnable; private Monitor monitor; /*** 构造函数** @param param 判断参数* @param condition 判定函数* @param runnable 执行内容*/public MonitorRunner(T param, Function condition, Runnable runnable) {this.param = param; this.condition = condition; this.runnable = runnable; monitor = new Monitor(); } @Overridepublic void run() {System.out.println("线程开始"); Monitor.Guard guard =new Monitor.Guard(monitor) {@Overridepublic boolean isSatisfied() {return condition.apply(param); }}; while (true) {if (monitor.enterIf(guard)) {try {runnable.run(); } finally {monitor.leave(); break; }} else {continue; }}} public T getParam() {return param; } public MonitorRunner setParam(T param) {this.param = param; return this; } public static void main(String[] args) {ExecutorService executorService =Executors.newFixedThreadPool(10, new CustomizableThreadFactory("MONITOR-")); MonitorRunner monitorRunner =new MonitorRunner<>(0,x -> x > 10,() -> {// todo 线程需要执行的内容System.out.println("今天天气真好"); }); executorService.submit(monitorRunner); while (monitorRunner.getParam() <= 10) {monitorRunner.setParam(monitorRunner.getParam() + 1); ThreadUtil.sleep(1000L); System.out.println("当前Param的值:" + monitorRunner.getParam()); }ThreadUtil.sleep(5000L); executorService.shutdown(); }}

代码说明
【Java|Java guava monitor监视器线程的使用详解】主要在构造对象的时候需要传递泛型的校验对象，以及断言和需要执行的Runable。
执行结果