- 浏览: 56475 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
shifulong:
cywhoyi 写道现在用Javassist代理也不错的看了一 ...
java动态代理(jdk &cglib) -
cywhoyi:
现在用Javassist代理也不错的
java动态代理(jdk &cglib)
写了一个线程安全的计数器(用锁显得多没有水平),非阻塞的,通过自旋的CAS操作达到数据一致性的效果
开始先说下原子变量和锁的比较
锁在高竞争的时候效率会高于原子变量,但是在中低竞争的时候原子变量的性能会好一些
类比:(交通拥堵时,交通信号灯能够实现更高的吞吐量,而在低拥堵时,环岛能实现更高的吞吐量)
知识点:
UnSafe的CAS操作
UnSafe的实例化
1.JDK适用UnSafe是通过下面的代码获取的
但是自定义使用UnSafe无法获取,会抛异常,原因如下代码。
2.构造函数私有化,无法new
3.么办法,只能反射了
CyclicBarrier(循环栅栏)
1.提供了两种初始化的构造方法
parties:到达栅栏的线程数目=parties,会释放栅栏
包含Runnable的构造方法,Runnable会在所有线程通过栅栏的时候触发
2.CyclicBarrier可以循环使用
下面是代码,分两个部分,计数器类和测试类
结果是1000*10=10000应该是正确的,在进行了上百次的测试的结果都是10000,程序应该没问题
finalVal : 0
finalVal : 10000
开始先说下原子变量和锁的比较
锁在高竞争的时候效率会高于原子变量,但是在中低竞争的时候原子变量的性能会好一些
类比:(交通拥堵时,交通信号灯能够实现更高的吞吐量,而在低拥堵时,环岛能实现更高的吞吐量)
知识点:
UnSafe的CAS操作
unsafe.compareAndSwapInt(this, valueOffset, oleVal, newVal)
UnSafe的实例化
1.JDK适用UnSafe是通过下面的代码获取的
private static final Unsafe unsafe = Unsafe.getUnsafe();
但是自定义使用UnSafe无法获取,会抛异常,原因如下代码。
public static Unsafe getUnsafe() { Class var0 = Reflection.getCallerClass(); if(var0.getClassLoader() != null) { throw new SecurityException("Unsafe"); } else { return theUnsafe; } }
2.构造函数私有化,无法new
3.么办法,只能反射了
try { Field field = Unsafe.class.getDeclaredField("theUnsafe"); field.setAccessible(true); unsafe = (Unsafe) field.get(Unsafe.class); } catch (Exception e) { e.printStackTrace(); }
CyclicBarrier(循环栅栏)
1.提供了两种初始化的构造方法
parties:到达栅栏的线程数目=parties,会释放栅栏
包含Runnable的构造方法,Runnable会在所有线程通过栅栏的时候触发
public CyclicBarrier(int parties) public CyclicBarrier(int parties, Runnable barrierAction)
2.CyclicBarrier可以循环使用
下面是代码,分两个部分,计数器类和测试类
import sun.misc.Unsafe; import java.io.Serializable; import java.lang.reflect.Field; public class CasCounter implements Serializable { private static Unsafe unsafe; private static long valueOffset; static { try { Field field = Unsafe.class.getDeclaredField("theUnsafe"); field.setAccessible(true); unsafe = (Unsafe) field.get(Unsafe.class); } catch (Exception e) { e.printStackTrace(); } try { valueOffset = unsafe.objectFieldOffset(CasCounter.class.getDeclaredField("value")); } catch (NoSuchFieldException e) { e.printStackTrace(); } } private volatile int value; public CasCounter() {value = 0;} public CasCounter(int initValue) {this.value = initValue;} public int getValue() { return value; } public int increment(int incrNum) {//线程安全 while (true) { int oleVal = value; int newVal = oleVal + incrNum; if (unsafe.compareAndSwapInt(this, valueOffset, oleVal, newVal)) { return newVal; } } } public int incrementNo(int incrNum) {//非线程安全 value += incrNum; return value; } }
import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier; public class Test { public static void main(String[] args) throws BrokenBarrierException, InterruptedException { final CasCounter casCounter = new CasCounter(); final CyclicBarrier cb = new CyclicBarrier(1001, new Runnable() { public void run() { System.out.printf("finalVal : %s \n", casCounter.getValue()); } }); for (int i = 0; i < 1000; i++) { new Thread(new Runnable() { public void run() { try { cb.await(); } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } for (int j = 0; j < 10; j++) { int curr = casCounter.increment(1); System.out.print("");//这行代码会增加冲突概率 } try { cb.await(); } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } } }).start(); } cb.await(); cb.await(); } }
结果是1000*10=10000应该是正确的,在进行了上百次的测试的结果都是10000,程序应该没问题
finalVal : 0
finalVal : 10000
发表评论
-
test
2016-02-26 17:45 423http://c.hiphotos.baidu.com/t ... -
java Integer的比较
2016-01-18 20:09 1027/** * A constant ... -
load过高排查
2016-01-07 19:15 1086jstack 线程的运行情况、线程的状态 load过高的 ... -
Runnable Callable Future FutrueTask ExecutorService的关系
2015-11-30 16:34 657public interface ExecutorSe ... -
单例模式以及序列化仍然单例的问题
2015-11-18 10:47 552这种方式仍然存在并发的同步阻塞问题,并且jdk1.5之 ... -
linux5种网络IO模型
2015-11-07 21:58 856看网上书上的各种解释太绕口难理解了,看到个例子挺好的。 ... -
nio学习记录 : start(buffer channel selector)
2015-11-06 22:17 723Buffer的capacity,limit,positio ... -
desgn partten : 适配器&门面
2015-11-05 11:55 532adapter adapter 一个接口转换成另一个接 ... -
java泛型中的PECS
2015-10-26 17:58 974extends List<? extends Nu ... -
spring自定义cache
2015-10-21 17:14 4509下面是一个较为详细的spring缓存的介绍 http:/ ... -
spring各种接口的作用FactoryBean、ApplicationContextAware、InitializingBean
2015-10-20 20:04 3006FactoryBean 当配置文件中<bean&g ... -
jvm调试命令
2015-10-14 15:42 463jps jps -mlv 列出当前jvm进程 ji ... -
java线程遇见的一个小问题(本质和线程无关都是基础知识)
2015-09-21 10:29 522猜猜下面几个程序,那个是线程安全的 NO1 public cl ... -
JUC--Parser
2015-09-08 16:27 649Java 7的并发包中推出了Phaser,其功能跟Cyclic ... -
JUC--Exchanger
2015-09-07 17:26 855Exchanger 用于线程之间数据交换,通过exchange ... -
java浮点型float遇到的一点问题
2015-04-10 16:32 643float 可以除以0,还可以不是一个数字 即Float.is ... -
java静态块的一个小坑
2015-04-07 18:26 596public class Student { pr ... -
java学习计划
2015-04-07 17:57 369刚入职的时候,team大神给制定的学习计划。 受益匪浅啊 ... -
购物网站(spring+mybatis+velocity+maven)项目
2015-04-03 18:06 950原文地址: http://www.iteye.com/top ... -
synchronized与static synchronized 的区别
2015-03-25 18:51 677基本上每个面试都问到了,面试命中率很大。 public cl ...
相关推荐
详细描述了cas 自定义登陆页面的配置与demo
对应博客:https://blog.csdn.net/fancheng614/article/details/84038266
CAS客户端自定义核心过滤器,继承CAS的AbstractCasFilter自定义AuthenticationFilter
我使用的cas-server-3.5.2版本,这个是已经修改好的。直接解压放到tomcat/webapp下就可以了
完整项目在https://download.csdn.net/download/u010588262/10327539 这个资源是新增功能之后的main文件夹 对应博客系列:https://blog.csdn.net/u010588262/article/category/7548325 对应博客这篇:...
包含cas源码、cas使用说明文档(包含配置信息)、连接数据库所需jar包、cas服务端自定义返回值等
让CAS支持客户端自定义登陆页面——服务器篇[参考].pdf
cas4.0版本的 单点登录 自定义页面。希望对你有用,最低资源分,辛苦分。有问题可以交流学习。谢谢
主要介绍了java中如何通过CAS算法实现线程安全,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,下面小编和大家一起来学习一下吧
线程安全 保护“共享数据” 低级并发工具 原子变量 锁(内部锁和显式锁) 线程安全容器 同步容器 并发容器 阻塞队列 高级线程协作工具 信号量 闭锁 关卡 fork-join Executor部分 ...
项目不是maven类,导入编译器的时候需注意,之前的部署流程可以网上查看其它文档,大体上都相同。
java多线程安全性基础介绍 线程安全 正确性 什么是线程安全性 原子性 竞态条件 i++ 读i ++ 值写回i 可见性 JMM 由于cpu和内存加载速度的差距,在两者之间增加了多级缓存导致,内存并不能直接对cpu可见。 ...
让CAS支持客户端自定义登陆页面----服务器篇--.doc
n cas-server-3.4.2\modules\cas-server-support-jdbc-3.4.2.jar 、 cas-server-integration-restlet-3.4.2.jar 拷贝到 D:\server\apache-tomcat-6.0.18\webapps\cas\WEB-INF\lib 目录下。 n 数据库驱动 jar 拷贝...
JAVA开发专家:敏捷Acegi、CAS:构建安全的Java系统 pdf
里面是验证码部分,加到CAS项目根目录即可。详见拙作https://blog.csdn.net/leftfist/article/details/84790650
偏向锁、轻量级锁和重量级锁不同的地方在于不是通过信号量机制(强制阻塞)而是通过自旋CAS实现互斥访问的,避免了强制阻塞时用户态与核心态之间切换带来的开销(系统调用),这里的开销主要是保存用户态的上下文...
cas-client 基于redis自定义实现、为实现自定义功能修改。可能会有bug,具体为何修改。可基于我的4.1自定义文档。
资源名称:敏捷Acegi、CAS.构建安全的Java系统资源截图: 资源太大,传百度网盘了,链接在附件中,有需要的同学自取。
4.CAS-自定义错误信息 5.CAS-识别json文件 6.CAS-页面缓存记住我 7.CAS-cookie设置 8.CAS-tgc设置 9.CAS-登出 10.CAS-redisCluster集群存储ticket(相应redis必须配置成cluster集群) 11.CAS-加密存储ticket 12.CAS-...