计算多个线程中的单个变量

Question

我有以下可运行的课程。

public class OnesRun implements Runnable {

    public int ones = 0;

    private int passendNumber;

    public OnesRun(int passendNumber) {
        this.passendNumber = passendNumber;
    }

    public void run() {
        if (passendNumber == 1)
            ones++;
    }

}

如果遇到 1，该类的每个实例都应该增加 ones 的值。

执行完所有线程后，我想从类外部读取 ones 的值。

1. 如何增加个 线程安全？
2. 我怎样才能访问 来自此类之外的one？ 通过静态变量？或者我可以将其放入应用程序中吗 语境？

---

编辑：

我希望下面的伪代码能让我的意图更加清晰。

OnesRun.ones = getCurrentValueOnes();

while ( (number = readNumbersFromFile) != null) {
   threadPool.execute(new OnesRun(number));
}

print("Overall values of ones " + OnesRun.ones);

Answer 1

如何增加线程安全性？

您可以使用 AtomicInteger。

我如何访问本课程之外的内容？通过静态变量？或者我可以将它放入应用程序上下文中吗？

您可以使用一个简单的吸气剂。或者我错过了什么？

更新

根据您的更新，以下是我将如何修改您的代码示例：

public class OnesRun implements Runnable {

    private static final AtomicInteger ones = new AtomicInteger();

    private final int passendNumber;

    public OnesRun(int passendNumber) {
        this.passendNumber = passendNumber;
    }

    public void run() {
        if (passendNumber == 1)
            OnesRun.ones.incrementAndGet();
    }

    public static void setOnes(int newValue) {
        ones.set(newValue);
    }

    public static int getOnes() {
        return ones.get()
    }
}

...

OnesRun.setOnes(getCurrentValueOnes());

while ( (number = readNumbersFromFile) != null) {
   threadPool.execute(new OnesRun(number));
}

print("Overall values of ones " + OnesRun.getOnes());

除了已经讨论过的内容（将 ones 设为 private static AtomicInteger 并添加 getter/setter 对），我将两个成员都设置为final，如果可能的话，这始终是可取的，尤其是在并发代码中。

另请注意，AtomicInteger 保留为实现细节 - 它不由类的公共接口公开。

Answer 2

使用 AtomicInteger （线程安全）和静态属性。

public class OnesRun implements Runnable {
    private static final AtomicInteger ones = new AtomicInteger();

    private int passendNumber;

    public OnesRun(int passendNumber) {
        this.passendNumber = passendNumber;
    }

    public void run() {
        if (passendNumber == 1) {
            ones.incrementAndGet();
        }
    }

    public static AtomicInteger getOnes() {
        return ones;
    }
}


OnesRun.getOnes().set(getCurrentValueOnes());

while ( (number = readNumbersFromFile) != null) {
    threadPool.execute(new OnesRun(number));
}

print("Overall values of ones " + OnesRun.getOnes().get());