JAVA语言多线程之同步容器的复合操方法
小标 2018-11-05 来源 : 阅读 864 评论 0

摘要:本文主要向大家介绍了JAVA语言多线程之同步容器的复合操方法,通过具体的内容向大家展示,希望对大家学习JAVA语言有所帮助。

本文主要向大家介绍了JAVA语言多线程之同步容器的复合操方法,通过具体的内容向大家展示,希望对大家学习JAVA语言有所帮助。


Java中给我们提供了一些同步容器(Collection),这些容器本身是线程安全的,但是对于一些复合操作,有时就需要额外的客户端加锁进行保护。复合操作包括迭代(反复获取元素,直到容器中的最后一个元素)、导航(根据一定顺序查找下一元素)、条件运算(比如缺少即加入)。这种复合操作对于本身是线程安全的同步容器来说,如果多个线程并发访问,可能就会出现问题。


比如,线程安全的vector容器,他的获取最后一个元素与删除最后一个元素方法。


public class VectorTest {

 private final Vector<integer> vector;

 

 public VectorTest() {

  vector = new Vector<>();

  for (int i = 0; i < 10; i++) {

vector.add(i);

  }

 

 }

 

 public int getVector() {

  int index = vector.size() - 1;

  try {

Thread.sleep(2000);

  } catch (InterruptedException e) {

e.printStackTrace();

  }

  return vector.get(index);

   

 }

 

 public void deleteVector() {

  int index = vector.size() - 1;

  vector.remove(index);

 }

 

 

 public static void main(String[] args) {

  VectorTest vectorTest = new VectorTest();

  new Thread(new Runnable() {

public void run() {

 vectorTest.getVector();

}

  }).start();

  new Thread(new Runnable() {

public void run() {

 vectorTest.deleteVector();

}

  }).start();

 }

}</integer>

   


执行结果



当没有使用客户端加锁的方式时,发现抛出了数组越界异常。可见本身线程安全的容器也会出现线程不安全的问题。


这是因为获取最后一个元素时,计算出了索引位置,但是此时线程休眠了,CPU被执行删除的线程抢走,将最后一个元素删除掉了,这是获取元素的线程再回来执行时,就会出现数组越界的异常,因为他要获取的元素已经被删掉了。


线程安全的容器在执行一个操作的时候是原子性的,但是多个操作一起执行,并且彼此有关系的时候就会出现问题,所以我们进行客户端加锁来解决这个问题。


public class VectorTest {

 private final Vector<integer> vector;

 

 public VectorTest() {

  vector = new Vector<>();

  for (int i = 0; i < 10; i++) {

vector.add(i);

  }

 

 }

 public int getVector(){

  synchronized (vector) {

int index = vector.size() - 1;

try {

 Thread.sleep(2000);

} catch (InterruptedException e) {

 e.printStackTrace();

}

return vector.get(index);

  }

 }

 public void deleteVector(){

  synchronized (vector) {

int index = vector.size() - 1;

vector.remove(index);

  }

 }

 

 public static void main(String[] args) {

  VectorTest vectorTest = new VectorTest();

  new Thread(new Runnable() {

public void run() {

 vectorTest.getVector();

}

  }).start();

  new Thread(new Runnable() {

public void run() {

 vectorTest.deleteVector();

}

  }).start();

 }

}</integer>

   


执行结果



可以发现执行成功了,使每个方法都必须获得相同的锁,保证了多个操作的原子性。但是这样削弱了并发性。


          

本文由职坐标整理并发布,希望对同学们有所帮助。了解更多详情请关注编程语言JAVA频道!


本文由 @小标 发布于职坐标。未经许可,禁止转载。
喜欢 | 1 不喜欢 | 0
看完这篇文章有何感觉?已经有1人表态,100%的人喜欢 快给朋友分享吧~
评论(0)
后参与评论

您输入的评论内容中包含违禁敏感词

我知道了

助您圆梦职场 匹配合适岗位
验证码手机号,获得海同独家IT培训资料
选择就业方向:
人工智能物联网
大数据开发/分析
人工智能Python
Java全栈开发
WEB前端+H5

请输入正确的手机号码

请输入正确的验证码

获取验证码

您今天的短信下发次数太多了,明天再试试吧!

提交

我们会在第一时间安排职业规划师联系您!

您也可以联系我们的职业规划师咨询:

小职老师的微信号:z_zhizuobiao
小职老师的微信号:z_zhizuobiao

版权所有 职坐标-一站式IT培训就业服务领导者 沪ICP备13042190号-4
上海海同信息科技有限公司 Copyright ©2015 www.zhizuobiao.com,All Rights Reserved.
 沪公网安备 31011502005948号    

©2015 www.zhizuobiao.com All Rights Reserved

208小时内训课程