package ratelimite;
import com.google.common.util.concurrent.RateLimiter;
public class RateLimiterDemo {
	public static void main(String[] args) {
		testNoRateLimiter();
		testWithRateLimiter();
	}
	public static void testNoRateLimiter() {
		long start = System.currentTimeMillis();
		for (int i = 0; i < 10; i++) {
			System.out.println("call execute.." + i);
		}
		long end = System.currentTimeMillis();
		System.out.println(end - start);
	}
	public static void testWithRateLimiter() {
		long start = System.currentTimeMillis();
		RateLimiter limiter = RateLimiter.create(10.0);
		// 每秒不超過(guò)10個(gè)任務(wù)被提交 
		for (int i = 0; i < 10; i++) {
			limiter.acquire();
			// 請(qǐng)求RateLimiter, 超過(guò)permits會(huì)被阻塞 
			System.out.println("call execute.." + i);
		}
		long end = System.currentTimeMillis();
		System.out.println(end - start);
	}
}

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.ListeningExecutorService;
import com.google.common.util.concurrent.MoreExecutors;
import com.google.common.util.concurrent.RateLimiter;
public class ListenableFutureDemo {
	public static void main(String[] args) {
		testRateLimiter();
		testListenableFuture();
	}
	/**
   * RateLimiter類似于JDK的信號(hào)量Semphore，他用來(lái)限制對(duì)資源并發(fā)訪問(wèn)的線程數(shù)
   */
	public static void testRateLimiter() {
		ListeningExecutorService executorService = MoreExecutors
		        .listeningDecorator(Executors.newCachedThreadPool());
		RateLimiter limiter = RateLimiter.create(5.0);
		// 每秒不超過(guò)4個(gè)任務(wù)被提交
		for (int i = 0; i < 10; i++) {
			limiter.acquire();
			// 請(qǐng)求RateLimiter, 超過(guò)permits會(huì)被阻塞
			final ListenableFuture<Integer> listenableFuture = executorService
			          .submit(new Task("is "+ i));
		}
	}
	public static void testListenableFuture() {
		ListeningExecutorService executorService = MoreExecutors
		        .listeningDecorator(Executors.newCachedThreadPool());
		final ListenableFuture<Integer> listenableFuture = executorService
		        .submit(new Task("testListenableFuture"));
		//同步獲取調(diào)用結(jié)果
		try {
			System.out.println(listenableFuture.get());
		}
		catch (InterruptedException e1) {
			e1.printStackTrace();
		}
		catch (ExecutionException e1) {
			e1.printStackTrace();
		}
		//第一種方式
		listenableFuture.addListener(new Runnable() {
			@Override
			      public void run() {
				try {
					System.out.println("get listenable future's result "
					              + listenableFuture.get());
				}
				catch (InterruptedException e) {
					e.printStackTrace();
				}
				catch (ExecutionException e) {
					e.printStackTrace();
				}
			}
		}
		, executorService);
		//第二種方式
		Futures.addCallback(listenableFuture, new FutureCallback<Integer>() {
			@Override
			      public void onSuccess(Integer result) {
				System.out
				            .println("get listenable future's result with callback "
				                + result);
			}
			@Override
			      public void onFailure(Throwable t) {
				t.printStackTrace();
			}
		}
		);
	}
}
class Task implements Callable<Integer> {
	String str;
	public Task(String str){
		this.str = str;
	}
	@Override
	  public Integer call() throws Exception {
		System.out.println("call execute.." + str);
		TimeUnit.SECONDS.sleep(1);
		return 7;
	}
}

<dependency>
      <groupId>com.google.guava</groupId>
      <artifactId>guava</artifactId>
      <version>14.0.1</version>
    </dependency>