安全发布，参数传递

Question

我有两个线程，每个线程都有自己的计数器：线程 A 有 counterA，线程 B 有 counterB。每个线程都必须使用两个计数器：线程 A 必须使用 counterA 和 counterB，线程 B 也必须同时使用两者。 我正在使用 AtomicInteger 并在两个线程之间共享计数器，我将它们作为参数传递给线程，每个线程将两个计数器存储在私有字段中。

// ...
AtomicInteger counterA = new AtomicInteger(0);
AtomicInteger counterB = new AtomicInteger(0);

Thread tA = new Thread(new RunnableA(counterA, counterB)); 
Thread tB = new Thread(new RunnableB(counterA, counterB)); 

// ... in the constructor of RunnableA ...
RunnableA(AtomicInteger counterA, AtomicInteger counterB) {
    this.counterA = counterA;
    this.counterB = counterB;
} 

//...
// The same for RunnableB

这是两个计数器中的safe publishing 吗？ 安全发布是必要的，因为对对象的引用不够安全，无法在线程之间共享对象。 在这种情况下如何实现安全发布？

提前致谢。

Answer 1

“安全发布”一词不适用于此。安全发布是关于在构造函数中创建的状态的发布。在您的示例中，AtomicInteger 对象是在调用构造函数之前创建的。

如果使用了其他类型，这可能安全也可能不安全，具体取决于是否以及如何发布 counterA 和 counterB 变量。但是，通过将计数器实现为AtomicInteger 对象，您无需担心发布问题。它们是原子/线程安全的，无论它们是如何发布的。唯一的可能关注可能是实例变量状态的发布。如果不查看其他班级，我们无法判断是否会发生这种情况。例如：

• 变量是final 还是volatile？
• 如果它们是非易失性和非最终的，对它们的访问是否正确同步？
• 在调用run() 之后它们是线程受限的吗？

请注意，runnables 将在当前线程中实例化，而不是在调用tA.start() 和tB.start() 时（如果）创建的线程中。当start() 被调用时，当前线程的start() 调用和新线程的run() 调用之间有一个happens-before。这意味着可以保证将变量安全地发布到子线程本身。只有将变量发布到其他线程才值得关注。