admin 管理员组

文章数量: 1184232

Concurrent

原创转载请注明出处：

 

有参方法acquire(int permits)表示每调用1次此方法，就使用Semaphore中的x个permits



Service.java

package org.fool.java.concurrent.semaphore.acquire;import java.util.concurrent.Semaphore;public class Service {private Semaphore semaphore = new Semaphore(10);public void testMethod() {try {semaphore.acquire(2);System.out.println(Thread.currentThread().getName() + " begin timer=" + System.currentTimeMillis());int sleepValue = 5000;System.out.println(Thread.currentThread().getName() + " stop " + (sleepValue / 1000) + " sec");Thread.sleep(sleepValue);System.out.println(Thread.currentThread().getName() + " end timer=" + System.currentTimeMillis());semaphore.release(2);} catch (InterruptedException e) {e.printStackTrace();}}
}

Note:

private Semaphore semaphore = new Semaphore(10);

定义10个permits，每次执行semaphore.acquire(2);消耗掉2个，所以10/2=5，说明同一时间只允许5个线程执行acquire()和release()之间的代码。 

ThreadA.java

package org.fool.java.concurrent.semaphore.acquire;public class ThreadA implements Runnable {private Service service;public ThreadA(Service service) {this.service = service;}@Overridepublic void run() {service.testMethod();}
}

SemaphoreTest.java

package org.fool.java.concurrent.semaphore.acquire;public class SemaphoreTest {public static void main(String[] args) throws InterruptedException {Service service = new Service();for (int i = 0; i < 10; i++) {new Thread(new ThreadA(service)).start();}}
}

Run


 

如果多次调用Semaphore的release()或release(int)方法时，还可以动态增加permits的个数。

package org.fool.java.concurrent.semaphore.acquire;import java.util.concurrent.Semaphore;public class SemaphoreTest2 {public static void main(String[] args) {try {Semaphore semaphore = new Semaphore(5);semaphore.acquire();semaphore.acquire();semaphore.acquire();semaphore.acquire();semaphore.acquire();System.out.println(semaphore.availablePermits());   // outputs 0semaphore.release();semaphore.release();semaphore.release();semaphore.release();semaphore.release();semaphore.release();System.out.println(semaphore.availablePermits());   // outputs 6semaphore.release(4);System.out.println(semaphore.availablePermits());   // outputs 10} catch (InterruptedException e) {e.printStackTrace();}}
}

Note:

Semaphore semaphore = new Semaphore(5);

 定义的5并不是最终的permits数量，仅仅是初始的状态值。

 

 

 

 

本文标签： Concurrent

版权声明：本文标题：Concurrent 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://roclinux.cn/p/1700321118a395735.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。