JAVA中怎么使用Lock和Condition手寫阻塞隊列

今天就跟大家聊聊有關(guān)JAVA中怎么使用Lock和Condition手寫阻塞隊列，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

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("準(zhǔn)備存數(shù)據(jù)了");
          blockingQueueClass.put(value);
          System.out.println("已經(jīng)存好數(shù)據(jù)了");
        }
      }
    });
    thread.start();
    
    Thread thread2 = new Thread(new Runnable() {
      @Override
      public void run() {
        while(true){
          System.out.println("準(zhǔn)備取數(shù)據(jù)了");
          Object value = blockingQueueClass.take();
          System.out.println("取到的數(shù)據(jù)為：" + 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;
    }
  }
}

看完上述內(nèi)容，你們對JAVA中怎么使用Lock和Condition手寫阻塞隊列有進(jìn)一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注億速云行業(yè)資訊頻道，感謝大家的支持。