/**
 * 同步代码块
 */
@Slf4j
public class SyncCodeBlock {
    private static final int COUNT = 5;

    public void syncCodeBlock(String block) {
        synchronized (this){
            for(int i =0;i<COUNT;i++){
                log.info("同步块{}并发-{}",block,i);
            }
        }
        for(int i =0;i<COUNT;i++){
            log.info("异步块{}并发-{}",block,i);
        }

    }
    public void asynCodeBlock(int block) {
        for(int i =0;i<COUNT;i++){
            log.info("代码块{}并发-{}",block,i);
        }
    }

    public static void main(String[] args) {
        ExecutorService executorService =Executors.newCachedThreadPool();
        SyncCodeBlock syncCodeBlock = new SyncCodeBlock();
        executorService.execute(()->{
            syncCodeBlock.syncCodeBlock("A");
        });
        executorService.execute(()->{
            syncCodeBlock.syncCodeBlock("B");
        });
    }
}

@Slf4j
public class SyncMethod {
    private static final int COUNT = 5;


    public synchronized void  syncMethod(String block) {
        for(int i =0;i<COUNT;i++){
//            log.info("同步{}并发-{}",block,i);
            System.out.println("同步"+block+"并发"+i);
        }
    }
    public void asynMethod(String block) {
        for(int i =0;i<COUNT;i++){
//            log.info("异步块{}并发-{}",block,i);
            System.out.println("异步"+block+"并发"+i);
        }
    }

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();
        SyncMethod syncMethod = new SyncMethod();
        executorService.execute(()->{
            syncMethod.syncMethod("A");

        });
        executorService.execute(()->{
            syncMethod.syncMethod("B");
        });
    }
}

public class SyncStaticMethod {
    private static final int COUNT = 10;

    public synchronized static void syncStaticMethod(String block){
        for(int i =0;i<COUNT;i++){
            System.out.println("静态同步"+block+"并发"+i);
        }
    }

    public static void asynStaticMethod(String block){
        for(int i =0;i<COUNT;i++){
            System.out.println("静态异步"+block+"并发"+i);
        }
    }


    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();
        for(int j= 0;j<10;j++){
            int finalJ = j;
            executorService.execute(() -> {
                SyncStaticMethod.syncStaticMethod(""+ finalJ);
            });
        }

    }

}

public class SyncStaticMethod {
    private static final int COUNT = 10;

    public synchronized static void syncStaticMethod(String block){
        for(int i =0;i<COUNT;i++){
            System.out.println("静态同步"+block+"并发"+i);
        }
    }

    public static void asynStaticMethod(String block){
        for(int i =0;i<COUNT;i++){
            System.out.println("静态异步"+block+"并发"+i);
        }
    }


    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();
        for(int j= 0;j<10;j++){
            int finalJ = j;
            executorService.execute(() -> {
                SyncStaticMethod.asynStaticMethod(""+ finalJ);
            });
        }

    }

}

public class SyncExample {

    static final int clientTotal = 30000;
    static final int threadTotal = 300;
    static int count = 0;

     synchronized void add() {
        count++;
    }

    public static void main(String[] args) throws Exception {
        SyncExample syncExample = new SyncExample();
        ExecutorService executorService = Executors.newCachedThreadPool();
        Semaphore semaphore = new Semaphore(threadTotal);
        CountDownLatch countDownLatch = new CountDownLatch(clientTotal);

        for(int i =0;i<clientTotal;i++){

            executorService.execute(()->{
                try {
                    semaphore.acquire();
                    syncExample.add();
                    semaphore.release();
                } catch (Exception e) {
                }
                countDownLatch.countDown();
            });
        }
        countDownLatch.await();
        executorService.shutdown();
        System.out.println("总计执行："+count);
    }
}