132133134135136137138139140141142
pool.close(); } public synchronized void execute (Runnable action) throws Closed { if (!pool.ready()) throw new Closed(); if (++jobs % this.maxPoolSize == 0 || pool.consumerCount() <= 0) supervise(); synchronized (pool) {