java - 在多个线程中计算单个变量

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++;
    }

}

此类的每个实例都应增加onesif 它遇到的值。

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

1. 如何增加ones 线程安全？
2. 我如何 ones从这个类之外访问？通过静态变量？或者我可以把它放到应用程序上下文中吗？

---

编辑：

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

OnesRun.ones = getCurrentValueOnes();

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

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

Answer 1

如何增加线程安全的？

您可以使用AtomicInteger.

我怎样才能从这个类之外访问那些？通过静态变量？或者我可以把它放到应用程序上下文中吗？

你可以使用一个简单的getter。还是我错过了什么？

更新

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

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 对）之外，我还创建了两个 members 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());