java - 使用 SynchronousQueue 解决消费者生产者并发问题。公平属性不起作用

Question

我在调试 SynchronousQueue 时遇到问题。它在 android studio 中，但它的 java 代码应该无关紧要。我将 true 传递给 SynchronousQueue 的构造函数，因此它的“公平”意味着它是一个 fifo 队列。但是不守规矩，还是让消费者先印，生产者后印。我遇到的第二个问题是我希望这些线程永不消亡，您认为我应该在生产者线程和消费者线程上使用 while 循环并让它们保持相互“生产和消费”吗？

这是我的简单代码:

   package com.example.android.floatingactionbuttonbasic;


import java.util.concurrent.SynchronousQueue;

import trikita.log.Log;


public class SynchronousQueueDemo {


    public SynchronousQueueDemo() {
    }


    public void startDemo() {
        final SynchronousQueue<String> queue = new SynchronousQueue<String>(true);

        Thread producer = new Thread("PRODUCER") {
            public void run() {
                String event = "FOUR";
                try {
                    queue.put(event); // thread will block here
                   Log.v("myapp","published event:", Thread
                           .currentThread().getName(), event);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }
        };

        producer.start(); // starting publisher thread

        Thread consumer = new Thread("CONSUMER") {
            public void run() {
                try {
                    String event = queue.take(); // thread will block here
                    Log.v("myapp","consumed event:", Thread
                            .currentThread().getName(), event);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }
        };

        consumer.start(); // starting consumer thread

    }

}

为了启动线程，我简单地调用了 new SynchronousQueueDemo().startDemo();

无论我将什么传递给 synchronousQueue 构造函数是“公平的”，日志总是看起来像这样:

/SynchronousQueueDemo$2$override(26747): myapp  consumed event: CONSUMER    FOUR
V/SynchronousQueueDemo$1$override(26747): myapp published event:PRODUCER    FOUR

检查 docs here ，它说了以下内容:

public SynchronousQueue(boolean fair) Creates a SynchronousQueue with the specified fairness policy. Parameters: fair - if true, waiting threads contend in FIFO order for access; otherwise the order is unspecified.

Answer 1

1. 公平策略与读取队列的顺序有关。生产者/消费者的执行顺序是消费者获取 ()，释放生产者(在 put() 上阻塞)。如果消费顺序很重要，设置fairness=true。

2. 如果您想让线程保持 Activity 状态，请设置一个在中断时表现良好的循环条件(见下文)。假设您想在生产者中放置一个 Thread.sleep() 以限制事件产生的速率。

   public void run() {
       boolean interrupted = false;
       while (!interrupted) {
           try {
                // or sleep, then queue.put(event)
                queue.take(event); 
           } catch (InterruptedException e) {
               interrupted = true;;
           }
       }
   }