通过 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,极大地简化了在并发情况下使用这些常用类的难度,让开发人员不在为并发而头疼。