JAVA中怎么使用Lock和Condition手写阻塞队列

今天就跟大家聊聊有关JAVA中怎么使用Lock和Condition手写阻塞队列，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。

package com.study;

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

public class BlockingQueueDemo {
  public static void main(String[] args) {
    BlockingQueueDemo blockingQueueDemo = new BlockingQueueDemo();
    final BlockingQueueClass blockingQueueClass = blockingQueueDemo.new BlockingQueueClass();
    Thread thread = new Thread(new Runnable() {
      @Override
      public void run() {
        while(true){
          int value = new Random().nextInt();
          System.out.println("准备存数据了");
          blockingQueueClass.put(value);
          System.out.println("已经存好数据了");
        }
      }
    });
    thread.start();
    
    Thread thread2 = new Thread(new Runnable() {
      @Override
      public void run() {
        while(true){
          System.out.println("准备取数据了");
          Object value = blockingQueueClass.take();
          System.out.println("取到的数据为：" + value);
        }
      }
    });
    thread2.start();
  }
  class BlockingQueueClass{
    Lock lock = new ReentrantLock();
    Condition notFullCondition = lock.newCondition();
    Condition notEmptyCondition = lock.newCondition();
    Object[] items = new Object[100];
    private int putLength,takeLength,count;
    
    public void put(Object object){
      lock.lock();
      try {
        while(count == items.length){
          try {
            notFullCondition.await();
          } catch (InterruptedException error) {
            error.printStackTrace();
          }
        }
        items[putLength] = object;
        if(++putLength == items.length){
          putLength = 0;
        }
        ++count;
        notEmptyCondition.signal();
      } catch (Exception e) {
        e.printStackTrace();
      } finally{
        lock.unlock();
      }
      
    }
    
    public Object take(){
      Object object = new Object();
      lock.lock();
      try {
        while(count == 0){
          try {
            notEmptyCondition.await();
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }
        object = items[takeLength];
        if(++takeLength == items.length){
          takeLength = 0;
        }
        --count;
        notFullCondition.signal();
      } catch (Exception e) {
        e.printStackTrace();
        lock.unlock();
      }
      return object;
    }
  }
}

看完上述内容，你们对JAVA中怎么使用Lock和Condition手写阻塞队列有进一步的了解吗？如果还想了解更多知识或者相关内容，请关注亿速云行业资讯频道，感谢大家的支持。