Nit*_*lra 2 java multithreading thread-safety accumulator apache-spark
我正在使用累加器,想知道这些对象是否是线程安全的?
accumInt
是的一种类型AccumulatorParam<Integer>
。
// Current value accumInt -> 6
AccumulatorThread t1 = new AccumulatorThread();
t1.setAccum(accumInt);
t1.setValueToAdd(5);
AccumulatorThread t2 = new AccumulatorThread();
t2.setAccum(accumInt);
t2.setValueToAdd(7);
new Thread(t1).start();
new Thread(t2).start();
System.out.println(accumInt.value()); // 11 or 13 or 18
Run Code Online (Sandbox Code Playgroud)
AccumlatorThread
类:
class AccumulatorThread implements Runnable {
Accumulator<Integer> accum;
Integer valueToAdd;
public Integer getValueToAdd() {
return valueToAdd;
}
public void setValueToAdd(Integer valueToAdd) {
this.valueToAdd = valueToAdd;
}
public Accumulator<Integer> getAccum() {
return accum;
}
public void setAccum(Accumulator<Integer> accum) {
this.accum = accum;
}
public void run() {
System.out.println("Value to Add in Thread : "+valueToAdd);
accum.add(valueToAdd);
}
}
Run Code Online (Sandbox Code Playgroud)
该行为表明它不是线程安全的。我想念什么吗?
OOC为什么同时在同一程序中设置和读取累加器?累加器通常由工作线程添加,并且只能由驱动程序线程读取。
Worker1: accumulator.add(increment)
Worker2: accumulator.add(someOtherIncrement)
Driver: println(accumulator.value)
Run Code Online (Sandbox Code Playgroud)
现在,您正在询问关于在驱动程序上的不同线程中设置/读取值的多线程处理。目的是什么?在这种情况下,只需使用本地JVM AtomicInteger
或即可AtomicLong
。
累加器是仅通过关联操作“添加”到的变量,因此可以有效地并行支持。