简单安全高效的Java计数器
2017-05-27 14:21
288 查看
本文利用AtomicLong实现了一个安全高效的计数器,利用线程池技术,测试结果符合预期,避免了线程并发操作变量问题,避免使用同步锁提高了效率。
package com.springapp.mvc;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicLong;
/**
* Created by acer on 2017/5/27.
*/
public class TestAtomic {
//AtomicLong 的api参考 http://www.tuicool.com/articles/uY3qIbB public static final AtomicLong atomicLong = new AtomicLong(0L);
public static void main(String[] args) {
ExecutorService executorService = Executors.newFixedThreadPool(10);
MyThread myThread = null;
for(int i = 0;i<100;i++){
myThread = new MyThread(atomicLong);
//ExecutorService的api中文解释【启动一次顺序关闭,执行以前提交的任务,但不接受新任务】 http://tool.oschina.net/apidocs/apidoc?api=jdk-zh executorService.submit(myThread);
}
executorService.shutdown();
System.out.println(atomicLong.get());
}
}
class MyThread extends Thread {
private AtomicLong atomicLong;
public MyThread(AtomicLong atomicLong){
this.atomicLong = atomicLong;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "正在执行。。。");
System.out.println(atomicLong.incrementAndGet());
}
}
package com.springapp.mvc;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicLong;
/**
* Created by acer on 2017/5/27.
*/
public class TestAtomic {
//AtomicLong 的api参考 http://www.tuicool.com/articles/uY3qIbB public static final AtomicLong atomicLong = new AtomicLong(0L);
public static void main(String[] args) {
ExecutorService executorService = Executors.newFixedThreadPool(10);
MyThread myThread = null;
for(int i = 0;i<100;i++){
myThread = new MyThread(atomicLong);
//ExecutorService的api中文解释【启动一次顺序关闭,执行以前提交的任务,但不接受新任务】 http://tool.oschina.net/apidocs/apidoc?api=jdk-zh executorService.submit(myThread);
}
executorService.shutdown();
System.out.println(atomicLong.get());
}
}
class MyThread extends Thread {
private AtomicLong atomicLong;
public MyThread(AtomicLong atomicLong){
this.atomicLong = atomicLong;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "正在执行。。。");
System.out.println(atomicLong.incrementAndGet());
}
}
相关文章推荐
- Java 安全:简单谈谈JAVA程序的反编译
- Linux管理员日记(5) 更简单高效:Linux邮件服务器的安装和安全
- Java高效计数器
- Java实现的高效计数器
- 在java中高效的计数器
- 一种安全、高效、简单的登陆算法
- cocos2d-x Jni c++ java互调 安全刷新UI控件最简单例子(下)
- [一天一点java]一个简单的计数器
- 关于如何用java实现一个高效的计数器
- Java高效计数器
- anic:比C快比Java安全比shell还简单的新语言
- 编写高效的java线程安全类
- 使用Java继承与泛型特性创建高效与安全的DAO对象
- Java高效计数器
- Java多线程 原子变量:最简单高效的tryLock
- 简单投票计数器java代码
- Java语言引入泛型的好处是安全简单
- 黑马程序员_java高效计数器
- cocos2d-x Jni c++ java互调 安全刷新UI控件最简单例子(上)