问题调试生产者消费者问题

Question

我正在尝试了解生产者消费者问题。为了重现这个问题，我写了下面的代码

package com.company;

import java.util.ArrayDeque;
import java.util.Queue;

public class ProducerConsumerProblem {

    private static Queue<Integer> q = new ArrayDeque<>(5);

    public static void main(String args[]) {

        Producer p = new Producer();
        Consumer c = new Consumer();

        Thread t = new Thread( p );
        Thread t1 = new Thread( c );

        t.start();
        t1.start();
    }

    public static class Producer implements Runnable {

        @Override
        public void run() {
            while(true) {
                if (q.size() == 5) {
                    continue;
                }
                System.out.println( "Adding to queue" );
                q.add( 1 );
            }
        }
    }
    public static class Consumer implements Runnable {

        @Override
        public void run() {
            while(true) {
                if (q.size() == 0) {
                    continue;
                }
                System.out.println( "Removing from queue" );
                q.remove();
            }
        }
    }
}

我原本希望得到类似 concurrent exception 的结果，但代码在队列为空或队列已满时停止。我的问题是为什么代码在队列为空或已满时停止，因为我将消费者和生产者都置于无限循环中，即使他们同时进行了错误的读取，但在稍后的某个时候他们会进行良好的读取并且生产者或消费者应该工作.请帮助我解决这个问题

Answer 1

这两个线程可能会看到 不同的 大小，因为您的代码不是线程安全的，并且您的添加和删除操作是在不同的线程上完成的。

当你在线程 1 上执行 q.add( 1 ); 时，它不一定将更新的数组写入内存（即 RAM），它可能仍在 CPU 寄存器中并且当上下文切换时对于这两个线程，您的更改也可能在第二个线程中消失，并且看不到更新的大小。如果您使用同步，同步块中的所有更改都将持久保存到 RAM 中，当同步块结束时，这样不需要的行为就不会再发生。

由于 ArrayDeque 不是线程安全的，您需要外部同步来确保您的代码线程安全，或者使用并发数据结构。

问题调试生产者消费者问题

problem debugging Producer consumer problem

java

multithreading

producer-consumer