我写了一个线程,为了进行内存同步,我必须使用Atomicinteger。这是我的代码:

public class NewClass implements Runnable {

public double rr;
public double rmse_new;
public double rmse_newT;
private int k;
private int[][] Xdisc;

public NewClass(int Xdisc[][], double[][] pat_cand, int k, double[][] Yresid, double[][] Xresid) {

    this.k = k;
    this.Xdisc = Xdisc;
}

@Override
public void run() {
    final AtomicInteger q = new AtomicInteger(0);
    q.set(0);
    while (true) {
        if (q.incrementAndGet() >= Xdisc.length) {
            break;

            Integer[] temp_X;
            temp_X = new Integer[Xdisc[0].length];
            for (int s = 0; s < Xdisc[0].length; s++) {
                temp_X[s] = Xdisc[q][s];
            }
        }
    }
}
}


问题是q是2D数组Xdisc的行索引(在主类中),显然应该是整数,但在NewClass中,q是AtomicInteger。因此我得到了这个错误:

incompatible types
required: int
found: AtomicInteger


在这条线

temp_X[s] = Xdisc[q][s];


我什至尝试

temp_X[s] = Xdisc[(int)q][s];


并得到此错误:

inconvertible types


反正有将AtomicInteger转换为int的方法吗?

最佳答案

如果您试图在整个循环中使用相同的值,则只需使用incrementAndGet()的返回值即可:

int index = q.incrementAndGet();
if (index >= Xdisc.length) {
    break;
} // I'm assuming you meant there to be a brace here...

Integer[] temp_X;
temp_X = new Integer[Xdisc[0].length];
for (int s = 0; s < Xdisc[0].length; s++) {
    temp_X[s] = Xdisc[index][s];
}


如果要使用绝对最新值,请使用get()

10-08 19:27