Eri*_*Rey 2 java concurrency atomicity
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;
public class _7_Synchronizing_Data_Access {
private AtomicInteger count;
private void incrementAndReport() {
System.out.print(count.incrementAndGet() + "here"); //does not print
}
public static void main(String[] args) {
ExecutorService service = null;
try {
service = Executors.newFixedThreadPool(20);
_7_Synchronizing_Data_Access manager = new _7_Synchronizing_Data_Access();
for (int i = 0; i < 10; i++)
service.submit(() -> manager.incrementAndReport());
} finally {
if (service != null)
service.shutdown();
}
}
}
Run Code Online (Sandbox Code Playgroud)
运行此程序不输出任何内容 甚至没有NullPointerException.如你所见,我没有实例化count.我希望它会引发错误.这是为什么?
将NullPointerException引发异常,并抓住了,但为了看他们,你需要检查Future通过返回的情况下service.submit调用:
按如下方式更改循环:
for (int i = 0; i < 10; i++) {
Future f = service.submit(() -> manager.incrementAndReport());
try {
System.out.println (f.get ());
}
catch (ExecutionException exex) {
System.out.println (exex);
}
catch (InterruptedException intEx) {
System.out.println (intEx);
}
}
Run Code Online (Sandbox Code Playgroud)
将输出:
java.util.concurrent.ExecutionException: java.lang.NullPointerException
java.util.concurrent.ExecutionException: java.lang.NullPointerException
java.util.concurrent.ExecutionException: java.lang.NullPointerException
java.util.concurrent.ExecutionException: java.lang.NullPointerException
java.util.concurrent.ExecutionException: java.lang.NullPointerException
java.util.concurrent.ExecutionException: java.lang.NullPointerException
java.util.concurrent.ExecutionException: java.lang.NullPointerException
java.util.concurrent.ExecutionException: java.lang.NullPointerException
java.util.concurrent.ExecutionException: java.lang.NullPointerException
java.util.concurrent.ExecutionException: java.lang.NullPointerException
Run Code Online (Sandbox Code Playgroud)
如果System.out.println(count.incrementAndGet() + "here");用try-catch 包围语句,你还会看到抛出异常:
private void incrementAndReport() {
try {
System.out.println(count.incrementAndGet() + "here"); //does not print
}
catch (Exception exc) {
System.out.println (exc);
}
}
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
75 次 |
| 最近记录: |