码迷,mamicode.com
首页 > 其他好文 > 详细

浅谈Semaphore类

时间:2018-11-02 18:55:55      阅读:164      评论:0      收藏:0      [点我收藏+]

标签:span   blog   允许   ide   class   trace   必须   初始   text   

Semaphore类有两个重要方法

1、semaphore.acquire();

请求一个信号量,这时候信号量个数-1,当减少到0的时候,下一次acquire不会再执行,只有当执行一个release()的时候,信号量不为0的时候才可以继续执行acquire

2、semaphore.release();

释放一个信号量,这时候信号量个数+1,

 

这个类使用的目的为:

如何控制某个方法允许并发访问线程的个数?

 

也就是说在线程里执行某个方法的时候,在方法里用该类对象进行控制,就能保证所有的线程中最多只有指定信号量个数个该方法在执行。

举例:

我开启了100个线程,执行一个showLog()方法,但是我只想要所有线程中,最多有五个线程在执行该方法,其他的线程就必须排队等待。

则可以使用Semaphore对象进行控制,该对象new初始化的时候有个int参数,即指定最多信号量个数。

 

 

 private Semaphore semaphore;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        semaphore = new Semaphore(5);

        for (int i = 0; i < 1000; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    showLog();
                }
            }).start();
        }


    }
    private void showLog(){
        try {
            semaphore.acquire();
            Log.i("xqxinfo","线程:"+Thread.currentThread().getName()+"执行了一个acquire请求操作");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        // 线程休眠1s
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        semaphore.release();
        Log.i("xqxinfo","线程:"+Thread.currentThread().getName()+"执行了一个release请求操作");


    }

 

技术分享图片

 

浅谈Semaphore类

标签:span   blog   允许   ide   class   trace   必须   初始   text   

原文地址:https://www.cnblogs.com/xqxacm/p/9894880.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!