多线程

线程安全6 - Semaphore:控制并发线程个数

2019-09-29  本文已影响0人  小超_8b2f

Semaphore可以维护当前访问自身的线程个数,并提供了同步机制。使用Semaphore可以控制同时访问资源的线程个数,例如,实现一个文件允许的并发访问数。

实例:
管理停车位,一个小的电子设备,实时性强就要Semaphore。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

public class TestSemaphore {
    private static final int NUM = 3;

    public static void main(String[] args) {
        ExecutorService service = Executors.newCachedThreadPool();
        final Semaphore sp = new Semaphore(3);
        
        for (int i = 0; i < 10; i++) {
            Runnable run = new Runnable() {
                @Override
                public void run() {
                    try {
                        sp.acquire();//获取坑位
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println("线程 " + Thread.currentThread().getName() 
                            + "进入,当前已有" + (NUM-sp.availablePermits() + "个并发"));
                    
                    try {
                        Thread.sleep((long)Math.random() * 10000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    
                    System.out.println("线程 " + Thread.currentThread().getName() + "即将离开");
                    
                    sp.release();//释放当前线程占用的坑位
                    System.out.println("线程 " + Thread.currentThread().getName() 
                            + "已离开,当前已有" + (NUM-sp.availablePermits() + "个并发"));
                    
                }
            }; //Runnable Def
            service.execute(run);
        } //for
        
        service.shutdown(); 
        while (!service.isTerminated()) {  
            try {
                Thread.sleep(200);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }  
        } 
        System.out.println("结束了!");
    }
    

}
上一篇 下一篇

猜你喜欢

热点阅读