package com.huangbei.test2;

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.Semaphore;

import static com.huangbei.util.Sleeper.sleep;

@Slf4j(topic = "c.TestSemaphore")
public class Test21 {
    public static void main(String[] args) {
        Data dataObject = new Data();
        int nThreads = 10;


        for (int i = 0; i < nThreads; i++) {
            new Thread(()->{
                log.debug("读取：{}",dataObject.read());
            }).start();
        }

    }

    static class Data {
        private Semaphore semaphore = new Semaphore(3);
        private String data = "Hello,Semaphore";


        public String read() {
            try {
                semaphore.acquire();
                sleep(1);
                return data;
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                semaphore.release();
            }
            return null;
        }


    }
    static class Counter{
        private int count;
        public void increment(){
            count++;
        }
        public int getCount(){
            return count;
        }
    }
}