【JavaEE】线程方法(三):wait-notify锁自定协调、线程安全(一).3:条件产生渡送执行、阻塞队列的解耦通信

synchronized (this) {
    while (size == data.length) {// 2.往后就是最后的 无能修改条件穿插的 临执行 无缝能改路，在官口检查条件
        this.wait();// 1.正确条件产生并唤醒它后 经历锁竞争 一路上渡到官口时 条件可能已经改变
    }
    // 3.官口通过,执行条件：
    data[tail] = elem;
    tail++;
    if (tail == data.length) {
        tail = 0;
    }
    size++;
    this.notify();// notify期望唤醒 take中的wait
}

渡前官口的二次检查：

渡前检查筛排送往 要加锁内的官口检查：

1.execute里面渡前

渡前并发环境下 一次筛排可能的才拿去送往 加锁开销大的官口检查

2.addWorker里面官口

官口加锁内 二次精确确定地检查

官路来源：

1.加锁

加锁造官路

2.原子指令

原子指令自带官路

渡路上并发读取筛送：

1.加锁官需要

加锁造官路 有开销 需在渡路上并发当时地读取筛排 少送至些

2.原子指令官不需要

CAS原子指令的官路 无开销 渡路上的全部送至都无所谓的

三、阻塞队列的解耦通信

1.直接交互

生产者消费者 直接交互地在自己身上实现 锁同步与锁协调

// 直接交互
class DirectInteraction {
    private String sharedData;
    private boolean dataReady = false;
    private final Object lock = new Object();

    // 生产者
    public void produce(String data) {
        synchronized(lock) {
            while(dataReady) { // 必须知道消费者的状态，等待消费者取走数据
                try { lock.wait(); } catch (InterruptedException e) {}
            }
            sharedData = data;
            dataReady = true; // 必须设置消费者需要的状态
            lock.notify();    // 必须直接通知消费者
        }
    }

    // 消费者
    public String consume() {
        synchronized(lock) {
            while(!dataReady) { // 必须知道生产者的状态，等待生产者提供数据
                try { lock.wait(); } catch (InterruptedException e) {}
            }
            String result = sharedData;
            dataReady = false;  // 必须设置生产者需要的状态
            lock.notify();      // 必须直接通知生产者
            return result;
        }
    }
}

1.1锁同步

在生产者消费者身上加锁同步，生产消费 都是整步地串行，处理了线程安全问题

1.2锁协调-乒乓交替协调

无缓冲区是在生产者消费者身上 锁块里 设置检查是否标记地 只能双方乒乓交替执行 地锁协调

1.2.1效率

始终在阻塞一方，随机调度下阻塞成了必须双方交替地执行，执行效率低

2.间接交互

生产者与消费者之间 引入中间组件-队列 解耦通信

// 间接交互
class IndirectInteraction {
    private BlockingQueue<String> queue = new ArrayBlockingQueue<>(10); // 已经在队列组件里 实现好了 生产消费的 锁同步与锁协调

    // 生产者
    public void produce(String data) {
        try {
            queue.put(data); // 生产者 只与共享的队列交互 调用队列里面的put方法即可，不关心消费者了
        } catch (InterruptedException e) {}
    }

    // 消费者
    public String consume() {
        try {
            return queue.take(); // 消费者 只与共享的队列交互 调用队列里面的take方法即可，不关心生产者了
        } catch (InterruptedException e) { return null; }
    }
}

2.1组件更换直接交互对象

内容互渗透、执行互拖欠 的紧密协调关系转移，生产者与消费者 改成与队列直接交互，彼此 间接交互 独立无联了

2.2组件分担功能实现给封装共享使用

2.2.1实现所需的同步协调机制

封装在队列里实现的 put、take方法 已加锁同步与用锁协调，生产者消费者 直接共享地使用实现

2.2.2额外实现缓冲区管理

队列能缓冲生产消费不同伐协调的待置数据，允许了 生产消费以不同的速度运行

2.2.2.1锁协调-队列连续协调

有缓冲区后是在队列组件上 锁块里 填取检查队列是否满空地 可以一方连续执行 地锁协调

2.2.2.1.1平衡速度

在队列满空下 阻塞限制一方连续执行、另方可连续执行地 实况平衡双方速度

2.2.2.1.2效率

只在队列满空时才会使另方阻塞，随机调度下双方少遇阻塞地可以连续地执行，执行效率高

2048 AI社区

有“AI”的1024 = 2048，欢迎大家加入2048 AI社区

更多推荐

项目拆解（二）：模型输出是‘野‘的——三层兜底+重分析，把AI变成可靠零件

前两层都过了，数据入库了，最后一步是上屏。但这里还有坑——模型在"无风险"时会返回什么？真机实测：它返回了[""]，甚至[" "]（带空格的空串）。前端直接渲染，用户看到一个红色的空警告框，吓一跳。?${esc">无，这段代码挺干净</span>'">无，这段代码挺干净</span>'先t.trim()再。只挡不住[" "]（带空格的字符串是真值），必须先清空格再过滤。这是真机踩出来的：第一次只写