java并发之Semaphore

public class SemaphoreTest {
    private static final int MAX_AVAILABLE=100;
    private final Semaphore available=new Semaphore(MAX_AVAILABLE,true);
    
    @Test
    public void test1()
    {
        ExecutorService threadPool=Executors.newCachedThreadPool();
        for (int i = 0; i < 300; i++) {
            threadPool.execute(new Runnable() {
                @Override
                public void run() {
                    try {
                        available.acquire();
                        System.out.println("save data");
                        available.release();
                    } catch (InterruptedException e) {
                    }
                }
            });
        }

        threadPool.shutdown();
    }
}