Java AtomicInteger类的使用方法详解
首先看两段代码，一段是Integer的，一段是AtomicInteger的，为以下：
publicclassSample1{
privatestaticIntegercount=0;
synchronizedpublicstaticvoidincrement(){
count++;
}
}
以下是AtomicInteger的：
publicclassSample2{
privatestaticAtomicIntegercount=newAtomicInteger(0);
publicstaticvoidincrement(){
count.getAndIncrement();
}
}
以上两段代码，在使用Integer的时候，必须加上synchronized保证不会出现并发线程同时访问的情况，而在AtomicInteger中却不用加上synchronized，在这里AtomicInteger是提供原子操作的，下面就对这进行相应的介绍。
AtomicInteger介绍
AtomicInteger是一个提供原子操作的Integer类，通过线程安全的方式操作加减。
AtomicInteger使用场景
AtomicInteger提供原子操作来进行Integer的使用，因此十分适合高并发情况下的使用。
AtomicInteger源码部分讲解
publicclassAtomicIntegerextendsNumberimplementsjava.io.Serializable{
privatestaticfinallongserialVersionUID=6214790243416807050L;
//setuptouseUnsafe.compareAndSwapIntforupdates
privatestaticfinalUnsafeunsafe=Unsafe.getUnsafe();
privatestaticfinallongvalueOffset;
static{
try{
valueOffset=unsafe.objectFieldOffset
(AtomicInteger.class.getDeclaredField("value"));
}catch(Exceptionex){thrownewError(ex);}
}
privatevolatileintvalue;
以上为AtomicInteger中的部分源码，在这里说下其中的value，这里value使用了volatile关键字，volatile在这里可以做到的作用是使得多个线程可以共享变量，但是问题在于使用volatile将使得VM优化失去作用，导致效率较低，所以要在必要的时候使用，因此AtomicInteger类不要随意使用，要在使用场景下使用。
AtomicInteger实例使用
以下就是在多线程情况下，使用AtomicInteger的一个实例，这段代码是借用IT宅中的一段代码。
publicclassAtomicTest{
staticlongrandomTime(){
return(long)(Math.random()*1000);
}
publicstaticvoidmain(String[]args){
//阻塞队列，能容纳100个文件
finalBlockingQueuequeue=newLinkedBlockingQueue(100);
//线程池
finalExecutorServiceexec=Executors.newFixedThreadPool(5);
finalFileroot=newFile("D:\\ISO");
//完成标志
finalFileexitFile=newFile("");
//原子整型，读个数
//AtomicInteger可以在并发情况下达到原子化更新，避免使用了synchronized，而且性能非常高。
finalAtomicIntegerrc=newAtomicInteger();
//原子整型，写个数
finalAtomicIntegerwc=newAtomicInteger();
//读线程
Runnableread=newRunnable(){
publicvoidrun(){
scanFile(root);
scanFile(exitFile);
}
publicvoidscanFile(Filefile){
if(file.isDirectory()){
File[]files=file.listFiles(newFileFilter(){
publicbooleanaccept(Filepathname){
returnpathname.isDirectory()||pathname.getPath().endsWith(".iso");
}
});
for(Fileone:files)
scanFile(one);
}else{
try{
//原子整型的incrementAndGet方法，以原子方式将当前值加1，返回更新的值
intindex=rc.incrementAndGet();
System.out.println("Read0:"+index+""+file.getPath());
//添加到阻塞队列中
queue.put(file);
}catch(InterruptedExceptione){
}
}
}
};
//submit方法提交一个Runnable任务用于执行，并返回一个表示该任务的Future。
exec.submit(read);
//四个写线程
for(intindex=0;index<4;index++){
//writethread
finalintnum=index;
Runnablewrite=newRunnable(){
StringthreadName="Write"+num;
publicvoidrun(){
while(true){
try{
Thread.sleep(randomTime());
//原子整型的incrementAndGet方法，以原子方式将当前值加1，返回更新的值
intindex=wc.incrementAndGet();
//获取并移除此队列的头部，在元素变得可用之前一直等待（如果有必要）。
Filefile=queue.take();
//队列已经无对象
if(file==exitFile){
//再次添加"标志"，以让其他线程正常退出
queue.put(exitFile);
break;
}
System.out.println(threadName+":"+index+""+file.getPath());
}catch(InterruptedExceptione){
}
}
}
};
exec.submit(write);
}
exec.shutdown();
}
}
AtomicInteger使用总结
AtomicInteger是在使用非阻塞算法实现并发控制，在一些高并发程序中非常适合，但并不能每一种场景都适合，不同场景要使用使用不同的数值类。
以上就是本文关于JavaAtomicInteger类的使用方法详解的全部内容，希望对大家有所帮助。感兴趣的朋友可以参阅：java原生序列化和Kryo序列化性能实例对比分析、关于Java企业级项目开发思想、Javamap存放数组并取出值代码详解等，有什么问题可以随时留言，小编会及时回复大家。