生产者线程卡住，但没有阻塞

Question

我有一组生产者-消费者线程，但根据 JConsole 堆栈跟踪，生产者被困在不是.put() 的代码行上。

class Producer implements Runnable {
    private final BlockingQueue<CopyOnWriteArrayList<Creature>> queue;
    private World myWorld;

    Producer(BlockingQueue<CopyOnWriteArrayList<Creature>> q, World myWorld) {
        queue = q;
        this.myWorld = myWorld;
    }

    public void run() {
        int nextTick = myWorld.myApp.getTick(); //'tick' is the current frame our main loop is on.      
        while (true) {
            if (myWorld.myApp.getTick() >= nextTick) { //if our world has updated to the next frame…
                nextTick = myWorld.myApp.getTick() + 1; //increment the next frame to wait for

                try {
                    for (int i = 0; i < myWorld.getCellController()
                            .getColumns(); i++) {
                        for (int j = 0; j < myWorld.getCellController()
                                .getRows(); j++) {

                            queue.put(myWorld.getCellController().Cells.get(i)
                                    .get(j));
                        }
                    }
                } catch (InterruptedException ex) {
                    System.out.println("INT! ******************************");
                } catch (NullPointerException ex) {
                    System.out.println("NULL! ******************************");
                } catch (ClassCastException ex) {
                    System.out.println("CAST! ******************************");
                } catch (IllegalArgumentException ex) {
                    System.out.println("ARG! ******************************");
                }
            }
        }
    }
}

根据堆栈跟踪，它只是停留在while(true) 行上，没有通过循环，即使它应该。

Stack trace:
Name: Producer
State: RUNNABLE
Total blocked: 0  Total waited: 196,958

Stack trace: 
concurrency.Producer.run(Setup.java:25)
java.lang.Thread.run(Thread.java:680)

第 25 行是 while(true) { 行。

Answer 1

getTick() 线程安全吗？ IE。在到达刻度值的过程中是否有同步的关键字、某种形式的锁、易失性读取或原子变量？如果没有，您的线程可能看不到对滴答计数器所做的并发更改。中断和调试可能会迫使这些更改可见。

此外，您的生产者似乎不应该等待成功的queue.put()，而是等待应用程序前进到下一个滴答声。 myWorld.myApp.getTick() 阻塞了吗？如果没有，您的代码将无限循环，除非：

• 还有其他线程同时修改滴答声
• 你的线程被挂起，另一个被唤醒的线程修改了刻度

只有在可能发生变化的情况下，使用无限循环来检查条件的变化（又名轮询/旋转等待）才有意义。

我建议在对象myWorld.myApp 中实现阻塞并安全地发布waitForTick(int tick)。除了线程安全集合之外，还有其他并发组件，如信号量、屏障等，可用于同步不同的线程。