Java同步方法怎么实现

Java同步方法怎么实现

本篇内容主要讲解“Java同步方法怎么实现”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Java同步方法怎么实现”吧!

  常用的同步方法是采用信号或加锁机制,确保资源在任意时刻至多被一个线程访问。Java语言在多线程编程上实现了完全对象化,提供了对同步机制的良好支持。

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同步方法怎么实现”有了更深的了解,不妨来实际操作一番吧!这里是恰卡编程网网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

发布于 2021-12-22 21:58:51
收藏
分享
海报
0 条评论
35
上一篇:Web前端的三大结构是什么 下一篇:Responsive Web Design响应式网页设计方法是什么
目录

    0 条评论

    本站已关闭游客评论,请登录或者注册后再评论吧~

    忘记密码?

    图形验证码