将无状态回调放入 BlockingQueue 是否安全？

Question

我有以下非常简单的回调接口和一个 POJO 类：

public interface Action{
    public void doAction();
}

public class Person{
     private String name;
     private String address;
     //...etc
     //GET, SET, toString
}

我将按如下方式使用它：

public class ActionExecutor{

    private static final Logger logger = LogManager.getLogger(ActionExecutor.class);
    private final BlockingQueue<Action> blockingQueue = new LinkedBlockingQueue(2000);

    public void execute(final Person p){
        //modify state of p in some way
        blockingQueue.put(new Action(){
            public void doAction(){
                logger.info("Execution started: " +p.toString );
                //do some other job
        });
    }
}

BlockingQueue这里用来实现生产者-消费者。

问题： 是否保证从BlockingQueue 执行操作的消费者线程将写入正确的日志消息？ IE。它观察到Person 的正确状态？但我并不确定。

我认为不，这不能保证，因为在生产者进行的修改和生产者阅读之间没有顺序之前发生。

Answer 1

答案是视情况而定。

如果您在此之后不再修改 Person 实例，那么它是有保证的。如in the docs 所述，存在发生前的关系：

内存一致性效果：与其他并发集合一样， 在将对象放入 BlockingQueue 之前线程中的操作 访问或删除该操作之后发生的操作 另一个线程中 BlockingQueue 中的元素。

但是，我仍然不会那样做。如果有人修改了 Person 实例之后回调已被放置在队列中，那么没有任何保证。您可以说，记录器保证打印的状态至少与添加到队列时一样最新。

所以消费者会看到这些修改：

public void execute(final Person p){
    //modify state of p in some way
    blockingQueue.put(new Action(){

但不是那些在那之后制作的。而且由于您在将p 传递给new Action() 对象后保留了它，所以我会避免这种情况。相反，我会这样做：

public void execute(final Person p){
    //modify state of p in some way
    blockingQueue.put(new Action() {
        final String executionName = p.toString();
        public void doAction(){
            logger.info("Execution started: " + executionName);
            //do some other job
    });
}

现在状态被捕获在一个最终变量中。无论p当时处于什么状态，消费者都会看到该值。