Java併発のSemaphoreアプリケーション
1531 ワード
Semaphoreは信号量を意味していますが、その使用原理はオペレーティングシステムのPVの原語と非常に似ていますので、これ以上話しません.以下はSemaphoreを使用した例です.
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
public class SemaphoreTest {
public static void main(String[] args) {
ExecutorService service = Executors.newCachedThreadPool();
final Semaphore sp = new Semaphore(3);
for (int i = 0; i < 10; i++) {
Runnable runnable = new Runnable() {
public void run() {
try {
sp.acquire();
} catch (InterruptedException e1) {
e1.printStackTrace();
}
System.out.println("Thread: "
+ Thread.currentThread().getName()
+ " gets in,we now have "
+ (3 - sp.availablePermits()) + " concurrent");
try {
Thread.sleep((long) (Math.random() * 10000));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Thread: "
+ Thread.currentThread().getName() + " is leaving");
sp.release();
}
};
service.execute(runnable);
}
service.shutdown();
}
}