手写Java线程池
练习手写线程池 import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.atomic.AtomicInteger; /** * ... * * @author : liangfen.zhou@huolala.cn * Date : 2018/12/18 下午4:48 */ public class TestPool { private int coreSize, maxSize; private AtomicInteger running = new AtomicInteger(0); private BlockingQueue<Runnable> queue; public TestPool(int coreSize, int maxSize, BlockingQueue<Runnable> queue) { this.coreSize = coreSize; this.maxSi...