并发限流处理

1. 固定时间窗口法
强制约定2s时间间隔内，最多允许10个并发，多余则拒绝/等待
缺点是不够平滑，0s-1s请求2个，1s-2s的时候请求了8个，2s-3s请求7个。看似限制住了，但1s-3s这两秒间隔中的并发并没有限制住，也就是不够平滑。

2. 滑动时间窗口发
基于1的基本思想，将时间间隔划分成更小，比如划分到0.1s为时间间隔，再不断淘汰旧的小时间间隔。
平滑度提高，但还是在两个相邻小时间间隔下有毛刺。

3. 基于令牌算法的并发处理 Semaphore
通过共享资源（令牌数）控制并发，将未获取到令牌的请求放到阻塞队列中。当有人释放令牌时，唤醒阻塞队列的等待线程。很像锁对吧。
https://zhuanlan.zhihu.com/p/98593407
```
public class Utils {

private static final int LIMIT = 5;
    /**
     * new Semaphore(10,true); 则为公平锁,否则默认不公平以提升性能
     */
    private static Semaphore SEMAPHORE = new Semaphore(LIMIT);

public static void main(String[] args) {
        for (int i = 0; i < 100; ++i) {
            try {
                SEMAPHORE.acquire();
                doSomeThing();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                SEMAPHORE.release();
            }
        }
    }
}
```

4. 基于漏桶算法的限速处理 RateLimiter
以指定速率提供令牌，无须归还。抢到了就执行，没抢到就进阻塞队列排队。可以做到控制速率。
https://cloud.tencent.com/developer/article/1408819
```
public class Utils {

private static final int LIMIT = 10;
    private static RateLimiter SEMAPHORE = RateLimiter.create(LIMIT);

public static void main(String[] args) {
        for (int i = 0; i < 100; ++i) {
            try {
                SEMAPHORE.acquire(1);
                doSomeThing();
            } catch (Exception e) {
                e.printStackTrace();
            } 
        }
    }
}
```