首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 开发语言 > 编程 >

透过 AtomicIntegerArray 或 AtomicInteger做简单的洪流控制【转】

2012-10-09 
通过 AtomicIntegerArray 或 AtomicInteger做简单的洪流控制【转】在设计系统的时候,为了防止雪崩效应我们都

通过 AtomicIntegerArray 或 AtomicInteger做简单的洪流控制【转】

在设计系统的时候,为了防止雪崩效应我们都需要加入一些洪流控制,比如你有多个分库的时候,你肯定不会希望见到某一个分库挂掉的时候把整个应用都拖垮,通过一个简单的计数器我们就可以实现简单的洪流控制。

JDK 最新提供的java.util.concurrent.*下的类简化了多线程的编程,atomic类采用经典的compareAndSet模式,在不同步锁的情况下保证了多线程的数据安全,进而极大地提升性能。

?

//并发控制器static AtomicIntegerArray floodCounter = new AtomicIntegerArray(16);//最大并发量public static int maxFloodCount = 10;//权重public static int QueryItemByIDFloodCount = 1;?public static void queryItemById(long id) {int db = (int) (id % 16);if (floodCounter.getAndAdd(db, QueryItemByIDFloodCount) > maxFloodCount) {System.out.println("I'am busy!");floodCounter.addAndGet(db, -QueryItemByIDFloodCount);return;}System.out.println("do somthing!");floodCounter.addAndGet(db, -QueryItemByIDFloodCount);}

这个包下面还有ConcurrentHashMap等系列的map,list,set,极大地简化了在并发情况下使用这些常用类的难度,让开发人员不在为并发而头疼。

热点排行