package com.ibeetl.admin.console.util.limitnetflow;
|
|
import com.google.common.util.concurrent.RateLimiter;
|
import org.checkerframework.checker.units.qual.A;
|
|
import java.text.SimpleDateFormat;
|
import java.util.concurrent.Executor;
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
import java.util.concurrent.ThreadPoolExecutor;
|
|
/**
|
* 令牌生成
|
* 基于内存的限流算法
|
*/
|
public class TokenFactory {
|
|
public static void init(){
|
RateLimiter rateLimiter = RateLimiter.create(10);
|
rateLimiter.acquire();
|
}
|
|
public static void main(String[] args) throws Exception{
|
|
|
System.out.println("-----out-----");
|
}
|
|
|
}
|