4.6 Lock 接口的深入-Java语言基础8-Java多线程

当前位置:　首页>> 技术小册>> Java语言基础8-Java多线程

- Lock 接口替换了同步 synchronized ，提供了更加灵活,性能更好的锁定操作。
- 返回线程的阻塞队列：

```bash
Condition newCondition();
```

生产者与消费者改进为 Lock 接口（借助 Condition 接口 (线程的阻塞队列)）： 
① 进入队列的线程，释放锁。
② 出去队列的线程，再次的获取锁。
③ 接口的方法 :  await() 线程释放锁,进入队列。
④ 接口的方法 :  signal() 线程出去队列,再次获取锁。
注意：线程的阻塞队列,依赖 Lock 接口创建。

示例：

```bash
package com.github.thread2.demo1;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * @author maxiaoke.com
 * @version 1.0
 * 
 */
public class Resource {
    private final Lock lock = new ReentrantLock();
    // 通过Lock接口锁，创建出2个线程的阻塞队列
    private final Condition prod = this.lock.newCondition(); // 生产者线程阻塞队列
    private final Condition cust = this.lock.newCondition(); // 消费者线程阻塞队列
    private int count;
    private boolean flag;

public void produce() {
        // 获取锁
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        this.lock.lock();
        while (this.flag) {
            // 无限等待，生产线程等待，执行到这里的线程，释放锁，进入到生产者的阻塞队列
            try {
                this.prod.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.count++;
        System.out.println("生产第：" + this.count + "个");
        // 修改标志位
        this.flag = true;
        // 唤醒消费线程队列中的一个
        this.cust.signal();
        // 释放锁
        this.lock.unlock();
    }

public void consume() {
        // 获取锁
        this.lock.lock();
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        while (!this.flag) {
            // 无限等待，消费线程等待，执行到这里的线程，释放锁，进入到消费者的阻塞队列
            try {
                this.cust.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("消费第：" + this.count);
        // 修改标志位
        this.flag = false;
        // 唤醒生产线程队列中的一个
        this.prod.signal();
        // 释放锁
        this.lock.unlock();
    }
}
```

```bash
package com.github.thread2.demo1;

/**
 * @author maxiaoke.com
 * @version 1.0
 * 
 */
public class Producer implements Runnable {
    private final Resource resource;

public Producer(Resource resource) {
        this.resource = resource;

}

@Override
    public void run() {
        while (true) {
            this.resource.produce();
        }
    }
}
```

```bash
package com.github.thread2.demo1;

/**
 * @author maxiaoke.com
 * @version 1.0
 * 
 */
public class Consumer implements Runnable {

private final Resource resource;

public Consumer(Resource resource) {
        this.resource = resource;
    }

@Override
    public void run() {
        while (true) {
            this.resource.consume();
        }
    }
}
```

```bash
package com.github.thread2.demo1;

/**
 * @author maxiaoke.com
 * @version 1.0
 * 
 */
public class Test {
    public static void main(String[] args) {
        Resource resource = new Resource();
        Producer producer = new Producer(resource);
        Consumer consumer = new Consumer(resource);
        new Thread(producer).start();
        new Thread(producer).start();
        new Thread(producer).start();
        new Thread(consumer).start();
        new Thread(consumer).start();

}
}
```

该分类下的相关小册推荐：

Java语言基础3-流程控制

Java高并发秒杀入门与实战

Mybatis合辑1-Mybatis基础入门

java源码学习笔记

Mybatis合辑4-Mybatis缓存机制

Java语言基础14-枚举和注解

Java语言基础16-JDK8 新特性

Java语言基础5-面向对象初级

Java必知必会-Maven高级

SpringBoot合辑-初级篇

深入理解Java虚拟机

Mybatis合辑5-注解、扩展、SQL构建