问题描述

当消费者远多于生产者的时候，使用ReentrantLock会出现数组越界

使用Lock实现的

package xyz.hans.learning_java.pro_cu.lock;  import xyz.hans.learning_java.pro_cu.common.IResource;  import java.util.ArrayList; import java.util.LinkedList; import java.util.List; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock;  /**  * Created by Hans on 16/10/22.  */ public class Resource implements IResource {     private List<String> mRes;     private static final int MAX = 20;     private static final Lock mLock = new ReentrantLock(true);     private static final Condition mEmptyCondition = mLock.newCondition();     private static final Condition mFullCondition = mLock.newCondition();      public Resource() {         mRes = new LinkedList<>();     }       public String getRes() {         mLock.lock();         if (mRes.size() <= 0) { //空仓的事后 则获取锁并且等待             try {                 System.out.println("空仓");                 mEmptyCondition.await();             } catch (InterruptedException e) {                 e.printStackTrace();             }         }         System.out.println("获取资源:" + mRes.get(0));         String res = mRes.remove(0);         mFullCondition.signalAll();         mLock.unlock();         return res;     }      public void addRes(String res) {         mLock.lock();         if (mRes.size() >= MAX) {             try {                 System.out.println("爆仓");                 mFullCondition.await();             } catch (InterruptedException e) {                 e.printStackTrace();             }         }         System.out.println("添加资源:" + res);         mRes.add(res);         mEmptyCondition.signalAll();         mLock.unlock();     } }

测试代码

        Resource res = new Resource();         for (int i = 1; i < 3; i++) {             new Productor("生产者:" + i, res).start();         }         for (int i = 1; i < 200; i++) {             new Customer("消费者:" + i, res).start();         } 

2个生产者线程 199个消费者线程

Console面板日志

生产者:1生产了0号资源 生产者:2生产了0号资源 添加资源:生产者:1的0号资源 生产者:1生产了1号资源 添加资源:生产者:2的0号资源 生产者:2生产了1号资源 添加资源:生产者:1的1号资源 生产者:1生产了2号资源 添加资源:生产者:2的1号资源 生产者:2生产了2号资源 添加资源:生产者:1的2号资源 生产者:1生产了3号资源 添加资源:生产者:2的2号资源 添加资源:生产者:1的3号资源 生产者:2生产了3号资源 生产者:1生产了4号资源 添加资源:生产者:2的3号资源 生产者:2生产了4号资源 添加资源:生产者:1的4号资源 生产者:1生产了5号资源 添加资源:生产者:2的4号资源 生产者:2生产了5号资源 添加资源:生产者:1的5号资源 生产者:1生产了6号资源 添加资源:生产者:2的5号资源 生产者:2生产了6号资源 添加资源:生产者:1的6号资源 生产者:1生产了7号资源 添加资源:生产者:2的6号资源 生产者:2生产了7号资源 添加资源:生产者:1的7号资源 生产者:1生产了8号资源 添加资源:生产者:2的7号资源 生产者:2生产了8号资源 添加资源:生产者:1的8号资源 生产者:1生产了9号资源 添加资源:生产者:2的8号资源 生产者:2生产了9号资源 获取资源:生产者:1的0号资源 消费者:1消费者消耗资源:生产者:1的0号资源 添加资源:生产者:1的9号资源 生产者:1生产了10号资源 添加资源:生产者:2的9号资源 生产者:2生产了10号资源 获取资源:生产者:2的0号资源 消费者:2消费者消耗资源:生产者:2的0号资源 添加资源:生产者:1的10号资源 生产者:1生产了11号资源 获取资源:生产者:1的1号资源 消费者:3消费者消耗资源:生产者:1的1号资源 添加资源:生产者:2的10号资源 生产者:2生产了11号资源 获取资源:生产者:2的1号资源 消费者:4消费者消耗资源:生产者:2的1号资源 添加资源:生产者:1的11号资源 生产者:1生产了12号资源 添加资源:生产者:2的11号资源 生产者:2生产了12号资源 获取资源:生产者:1的2号资源 消费者:5消费者消耗资源:生产者:1的2号资源 获取资源:生产者:2的2号资源 消费者:6消费者消耗资源:生产者:2的2号资源 添加资源:生产者:1的12号资源 生产者:1生产了13号资源 添加资源:生产者:2的12号资源 生产者:2生产了13号资源 获取资源:生产者:1的3号资源 消费者:7消费者消耗资源:生产者:1的3号资源 获取资源:生产者:2的3号资源 消费者:8消费者消耗资源:生产者:2的3号资源 添加资源:生产者:1的13号资源 生产者:1生产了14号资源 添加资源:生产者:2的13号资源 生产者:2生产了14号资源 获取资源:生产者:1的4号资源 消费者:9消费者消耗资源:生产者:1的4号资源 获取资源:生产者:2的4号资源 消费者:10消费者消耗资源:生产者:2的4号资源 添加资源:生产者:1的14号资源 生产者:1生产了15号资源 获取资源:生产者:1的5号资源 消费者:11消费者消耗资源:生产者:1的5号资源 添加资源:生产者:2的14号资源 生产者:2生产了15号资源 获取资源:生产者:2的5号资源 消费者:12消费者消耗资源:生产者:2的5号资源 获取资源:生产者:1的6号资源 消费者:13消费者消耗资源:生产者:1的6号资源 添加资源:生产者:1的15号资源 生产者:1生产了16号资源 获取资源:生产者:2的6号资源 消费者:14消费者消耗资源:生产者:2的6号资源 添加资源:生产者:2的15号资源 生产者:2生产了16号资源 获取资源:生产者:1的7号资源 消费者:15消费者消耗资源:生产者:1的7号资源 添加资源:生产者:1的16号资源 生产者:1生产了17号资源 获取资源:生产者:2的7号资源 消费者:16消费者消耗资源:生产者:2的7号资源 添加资源:生产者:2的16号资源 生产者:2生产了17号资源 获取资源:生产者:1的8号资源 消费者:17消费者消耗资源:生产者:1的8号资源 添加资源:生产者:1的17号资源 生产者:1生产了18号资源 获取资源:生产者:2的8号资源 消费者:18消费者消耗资源:生产者:2的8号资源 添加资源:生产者:2的17号资源 生产者:2生产了18号资源 获取资源:生产者:1的9号资源 消费者:19消费者消耗资源:生产者:1的9号资源 添加资源:生产者:1的18号资源 生产者:1生产了19号资源 获取资源:生产者:2的9号资源 消费者:20消费者消耗资源:生产者:2的9号资源 获取资源:生产者:1的10号资源 消费者:21消费者消耗资源:生产者:1的10号资源 添加资源:生产者:2的18号资源 生产者:2生产了19号资源 获取资源:生产者:2的10号资源 消费者:22消费者消耗资源:生产者:2的10号资源 获取资源:生产者:1的11号资源 消费者:23消费者消耗资源:生产者:1的11号资源 添加资源:生产者:1的19号资源 生产者:1生产了20号资源 获取资源:生产者:2的11号资源 消费者:24消费者消耗资源:生产者:2的11号资源 获取资源:生产者:1的12号资源 消费者:25消费者消耗资源:生产者:1的12号资源 添加资源:生产者:2的19号资源 生产者:2生产了20号资源 获取资源:生产者:2的12号资源 消费者:26消费者消耗资源:生产者:2的12号资源 获取资源:生产者:1的13号资源 消费者:27消费者消耗资源:生产者:1的13号资源 获取资源:生产者:2的13号资源 消费者:28消费者消耗资源:生产者:2的13号资源 添加资源:生产者:1的20号资源 生产者:1生产了21号资源 获取资源:生产者:1的14号资源 消费者:29消费者消耗资源:生产者:1的14号资源 获取资源:生产者:2的14号资源 消费者:30消费者消耗资源:生产者:2的14号资源 添加资源:生产者:2的20号资源 生产者:2生产了21号资源 获取资源:生产者:1的15号资源 消费者:31消费者消耗资源:生产者:1的15号资源 获取资源:生产者:2的15号资源 消费者:32消费者消耗资源:生产者:2的15号资源 获取资源:生产者:1的16号资源 消费者:33消费者消耗资源:生产者:1的16号资源 获取资源:生产者:2的16号资源 消费者:34消费者消耗资源:生产者:2的16号资源 添加资源:生产者:1的21号资源 生产者:1生产了22号资源 获取资源:生产者:1的17号资源 消费者:35消费者消耗资源:生产者:1的17号资源 获取资源:生产者:2的17号资源 消费者:36消费者消耗资源:生产者:2的17号资源 获取资源:生产者:1的18号资源 消费者:37消费者消耗资源:生产者:1的18号资源 添加资源:生产者:2的21号资源 生产者:2生产了22号资源 获取资源:生产者:2的18号资源 消费者:38消费者消耗资源:生产者:2的18号资源 获取资源:生产者:1的19号资源 消费者:39消费者消耗资源:生产者:1的19号资源 获取资源:生产者:2的19号资源 消费者:40消费者消耗资源:生产者:2的19号资源 获取资源:生产者:1的20号资源 消费者:41消费者消耗资源:生产者:1的20号资源 获取资源:生产者:2的20号资源 消费者:42消费者消耗资源:生产者:2的20号资源 添加资源:生产者:1的22号资源 生产者:1生产了23号资源 获取资源:生产者:1的21号资源 消费者:43消费者消耗资源:生产者:1的21号资源 获取资源:生产者:2的21号资源 消费者:44消费者消耗资源:生产者:2的21号资源 获取资源:生产者:1的22号资源 消费者:45消费者消耗资源:生产者:1的22号资源 空仓 空仓 添加资源:生产者:2的22号资源 生产者:2生产了23号资源 获取资源:生产者:2的22号资源 消费者:48消费者消耗资源:生产者:2的22号资源 空仓 空仓 空仓 空仓 空仓 空仓 空仓 添加资源:生产者:1的23号资源 生产者:1生产了24号资源 获取资源:生产者:1的23号资源 消费者:56消费者消耗资源:生产者:1的23号资源 空仓 空仓 空仓 空仓 空仓 空仓 Exception in thread "消费者:46" java.lang.IndexOutOfBoundsException: Index: 0, Size: 0     at java.util.LinkedList.checkElementIndex(LinkedList.java:553)     at java.util.LinkedList.get(LinkedList.java:474)     at xyz.hans.learning_java.pro_cu.lock.Resource.getRes(Resource.java:37)

请求帮助

• 为何在锁的情况下还会产生这种问题？

• 如何完美解决呢？

谢谢您的回复