作为技术岗，进入一家企业不但要经历面试，还会有一些笔试题目。通过整理发现“如何保障同一资源被多个线程并发方位时的完整性？”是被提问次数比较多的问题。今天就和大家一起来学习一下这个面试题的解决方案。
常用的同步方法是采用信号或加锁机制，确保资源在任意时刻至多被一个线程访问。Java语言在多线程编程上实现了完全对象化，提供了对同步机制的良好支持。
在Java中一共有四种方法支持同步，其中前三个是同步方法，一个是管道方法。管道方法不建议使用，阻塞队列方法在问题4已有描述，现只提供前两种实现方法。
- wait()/notify()方法
- await()/signal()方法
- BlockingQueue阻塞队列方法
- PipedInputStream/PipedOutputStream
一、生产者类：
```
public class Producer extends Thread { // 每次生产的产品数量
private int num;
// 所在放置的仓库
private Storage storage;
// 构造函数，设置仓库
public Producer(Storage storage) {
this.storage = storage;
}
// 线程run函数
public void run() {
produce(num);
}
// 调用仓库Storage的生产函数
public void produce(int num) {
storage.produce(num);
}
public int getNum() {
return num;
}
public void setNum(int num) {
this.num = num;
}
public Storage getStorage() {
return storage;
}
public void setStorage(Storage storage) {
this.storage = storage;
}
}
```
二、消费者类：
```
public class Consumer extends Thread { // 每次消费的产品数量
private int num;
// 所在放置的仓库
private Storage storage;
// 构造函数，设置仓库
public Consumer(Storage storage) {
this.storage = storage;
}
// 线程run函数
public void run() {
consume(num);
}
// 调用仓库Storage的生产函数
public void consume(int num) {
storage.consume(num);
}
// get/set方法
public int getNum() {
return num;
}
public void setNum(int num) {
this.num = num;
}
public Storage getStorage() {
return storage;
}
public void setStorage(Storage storage) {
this.storage = storage;
}
}
```
仓库类：(wait()/notify()方法)
```
public class Storage { // 仓库最大存储量
private final int MAX_SIZE = 100;
// 仓库存储的载体
private LinkedList list = new LinkedList();
// 生产num个产品
public void produce(int num) {
// 同步代码段
synchronized (list) {
// 如果仓库剩余容量不足
while (list.size() + num > MAX_SIZE) {
System.out.print("【要生产的产品数量】:" + num);
System.out.println(" 【库存量】:" + list.size() + " 暂时不能执行生产任务!");
try {
list.wait();// 由于条件不满足，生产阻塞
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// 生产条件满足情况下，生产num个产品
for (int i = 1; i <= num; ++i) {
list.add(new Object());
}
System.out.print("【已经生产产品数】:" + num);
System.out.println(" 【现仓储量为】:" + list.size());
list.notifyAll();
}
}
// 消费num个产品
public void consume(int num) {
// 同步代码段
synchronized (list) {
// 如果仓库存储量不足
while (list.size() < num) {
System.out.print("【要消费的产品数量】:" + num);
System.out.println(" 【库存量】:" + list.size() + " 暂时不能执行生产任务!");
try {
// 由于条件不满足，消费阻塞
list.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// 消费条件满足情况下，消费num个产品
for (int i = 1; i <= num; ++i) {
list.remove();
}
System.out.print("【已经消费产品数】:" + num);
System.out.println(" 【现仓储)量为】:" + list.size());
list.notifyAll();
}
}
// get/set方法
public LinkedList getList() {
return list;
}
public void setList(LinkedList list) {
this.list = list;
}
public int getMAX_SIZE() {
return MAX_SIZE;
}
}
```
仓库类：(await()/signal()方法)
```
public class Storage { // 仓库最大存储量
// 仓库最大存储量
private final int MAX_SIZE = 100;
// 仓库存储的载体
private LinkedList list = new LinkedList();
// 锁
private final Lock lock = new ReentrantLock();
// 仓库满的条件变量
private final Condition full = lock.newCondition();
// 仓库空的条件变量
private final Condition empty = lock.newCondition();
// 生产num个产品
public void produce(int num) {
// 获得锁
lock.lock();
// 如果仓库剩余容量不足
while (list.size() + num > MAX_SIZE) {
System.out.print("【要生产的产品数量】:" + num);
System.out.println(" 【库存量】:" + list.size() + " 暂时不能执行生产任务!");
try {
// 由于条件不满足，生产阻塞
full.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// 生产条件满足情况下，生产num个产品
for (int i = 1; i <= num; ++i) {
list.add(new Object());
}
System.out.print("【已经生产产品数】:" + num);
System.out.println(" 【现仓储量为】:" + list.size());
// 唤醒其他所有线程
full.signalAll();
empty.signalAll();
// 释放锁
lock.unlock();
}
// 消费num个产品
public void consume(int num) {
// 获得锁
lock.lock();
// 如果仓库存储量不足
while (list.size() < num) {
System.out.print("【要消费的产品数量】:" + num);
System.out.println(" 【库存量】:" + list.size() + " 暂时不能执行生产任务!");
try {
// 由于条件不满足，消费阻塞
empty.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// 消费条件满足情况下，消费num个产品
for (int i = 1; i <= num; ++i) {
list.remove();
}
System.out.print("【已经消费产品数】:" + num);
System.out.println(" 【现仓储)量为】:" + list.size());
// 唤醒其他所有线程
full.signalAll();
empty.signalAll();
// 释放锁
lock.unlock();
}
// set/get方法
public int getMAX_SIZE() {
return MAX_SIZE;
}
public LinkedList getList() {
return list;
}
public void setList(LinkedList list) {
this.list = list;
}
以上就是“如何保障同一资源被多个线程并发方位时的完整性？”的解决方案。关注博学谷资讯页面，后期会为大家提供更多的关于java面试的题目以及解析。
— 申请免费试学名额 —
在职想转行提升，担心学不会？根据个人情况规划学习路线，闯关式自适应学习模式保证学习效果
讲师一对一辅导，在线答疑解惑，指导就业！
上一篇：
初级Java程序员需要注意的问题
下一篇：
自学Java开发方法有哪些？如何高效自学
相关推荐 更多
Java开发中静态变量和实例变量的区别是什么?
Java开发中静态变量和实例变量的区别是什么?在语法定义上的区别：静态变量前要加 static 关键字，而实例变 量前则不加。
3124
2019-05-24 14:16:01
Java基础开发的集合类都有哪些？主要方法有什么？
你所知道的Java基础开发的集合类都有哪些？主要方法有什么？最常用的集合类是 List 和 Map。 List 的具体实现包括ArrayList 和 Vector，它们是可变大小的列表，比较适合构建、存储和操作任何类型对象的元素列表。 List 适用于按数值索引访问元素的情形。
3124
2019-06-03 11:16:40
Java面试题之面向对象整理附答案
面向对象以数据为中心的开发方式，使用继承来简化开发过程，使用接口来规范对数据的操作，使用多态达到操作的灵活性。可以说面向对象是Java面试中的一个常见重要考点，因此本文为大家整理了面向对象的相关面试题，其中包括面向对象的特性、访问权限修饰符和clone对象的理解。大家可以结合着参考答案，梳理一遍面向对象的相关知识点。
2558
2019-12-04 14:01:29
MyBatis十大经典面试题整理附答案
MyBatis作为一个备受欢迎的持久层框架，有着支持普通SQL查询，存储过程和高级映射等优势。这也是为什么大家都爱使用MyBatis的原因。在面试过程中，MyBatis也是面试官常常会考察求职者的知识点之一，本文应许多面试者的要求，为大家整理了十大经典的MyBatis面试题和对应的答案，有面试需求的小伙伴不妨一起来复习一下。
1619
2020-01-15 20:40:47
百度、腾讯、阿里招聘常见的Java面试真题
百度、腾讯、阿里招聘常见Java面试真题，面试在求职中是一项非常重要的内容，面试中表现往往决定着求职者是否可以被录用。面试过程中做好充足准备，有技巧地应对考官的提问可能会给整个面试加分。
980
2020-06-23 10:14:42
掌握Java常用API提高编程效率
免费 基础 1875
分布式服务框架Dubbox
¥59 进阶 25
百度地图API应用开发
免费 进阶 1504
Java架构师体验课
¥9.9 进阶 82
Spring Security Oauth2.0专题
免费 基础 1480
推荐课程
热门文章
- 前端测试用例怎么写？为什么写测试用例？
- 有哪些好的线上培训产品经理的机构？
- 零经验的人学编程难吗？能学会吗？
- 传智博学谷神经网络和深度学习课程推荐
- 区块链应用未来的几个方向有哪些？
- Python爬虫需要学多久才能掌握？
- 30岁能进入人工智能行业吗？晚不晚？
- 黑马Java架构师课程知识点有哪些？
- 选择Java培训班应该咨询什么内容？
- jQuery框架安装及jQuery特点介绍 查看更多
扫描二维码，了解更多信息
