使用信号量来 限制无边界池子与队列

public class BoundedExecutor {
     private final Executor exec;
     private final Semaphore semaphore;

     public BoundedExecutor(Executor exec, int bound) {
            this. exec = exec;
            this. semaphore = new Semaphore(bound);
     }

     public void submitTask( final Runnable command) throws InterruptedException {
            semaphore.acquire();
            try {
                 exec. execute(new Runnable() {
                      public void run() {
                            try {
                                command.run();
                           } finally {
                                 semaphore.release();
                           }
                     }
                });
           } catch (RejectedExecutionException e) {
                 semaphore.release();
           }
     }
}