Java中线程无法访问可共享资源

Question

我无法理解为什么 Consumers 中的共享列表始终为空，而 Provider 却向其中添加值。 我有提供者：

class Provider extends Thread {
    List<Integer> products;
    Random rnd = new Random();

    public Provider(List<Integer> products) {
        this.products = products;
    }

    @Override
    public void run() {
        //Provider just generate random value and adds the value to the shared list
        for (int i = 0; i < 10; i++) {
            Integer product = rnd.nextInt(100);
            System.out.println("added value: "+product);
            products.add(product);
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

和消费者：

class Consumer extends Thread {
    List<Integer> products;

    public Consumer(List<Integer> products) {
        this.products = products;
    }

    @Override
    public void run() {
        System.out.println("Consumer started");
        for (int i = 0; i < 5;) {
            //Consumer just removes elements from shared list five times
            if (!products.isEmpty()) {
                Integer product = products.remove(0);
                System.out.println("removed: "+product);
                i++;
            }
        }
        System.out.println("Consumer stopped");
    }
}

主要有以下内容：

List<Integer> products = new ArrayList<>();
new Provider(products).start();
new Consumer(products).start();
new Consumer(products).start();

我认为每个消费者在提供者向可共享列表添加值后应该从可共享列表中读取五个值，但在消费者中列表始终为空。为什么列表不更新？

我得到以下结果：

Consumer started
Consumer started
added value: 13
removed: 13
removed: 13
added value: 28
added value: 53
added value: 32
added value: 85
added value: 23
added value: 60
added value: 10
added value: 15
added value: 85

提供者完成后，消费者正在工作，但由于这种情况无法删除任何项目。

请不要写同步。我知道线程应该同步对公共资源的访问。但这是研究示例，我的目标是让消费者阅读并从列表中删除值。

Answer 1

我认为第一条评论击中要害。如果没有任何同步，则不能保证线程看到更新。尤其是像这样的紧密循环。

添加同步到消费者对我来说很有效。

class Consumer extends Thread {
    List<Integer> products;

    public Consumer(List<Integer> products) {
        this.products = products;
    }

    @Override
    public void run() {
        System.out.println("Consumer started");
        for (int i = 0; i < 5;) {
            //Consumer just removes elements from shared list five times
            synchronized(products){
                if (!products.isEmpty()) {
                    Integer product = products.remove(0);
                    System.out.println("removed: "+product);
                    i++;
                }
            }
        }
        System.out.println("Consumer stopped");
    }
}

当我在没有同步的情况下尝试此操作时，消费者永远不会从列表中获取。