Java言語 同時スレッドのSemaphoreクラス

package com.startnews24;

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

public class MySemaphore extends Thread {

private int i;
private Semaphore semaphore;

public MySemaphore(int i,Semaphore semaphore){
this.i = i;
this.semaphore = semaphore;
}

public void run(){
if(semaphore.availablePermits() > 0){
System.out.println(“"+i+"席がある : “);
}else{
System.out.println(“"+i+"席がありません “);
}
try {
semaphore.acquire();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(“"+i+"席を確保");
try {
Thread.sleep((int)Math.random()*10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(“"+i+"使用完了");
semaphore.release();
}
public static void main(String[] args) {
Semaphore semaphore = new Semaphore(2);
ExecutorService service = Executors.newCachedThreadPool();
for(int i = 0 ;i<10 ; i++){ service.execute(new MySemaphore(i,semaphore)); } service.shutdown(); semaphore.acquireUninterruptibly(2); System.out.println("使用後クリーンアップ"); semaphore.release(2); } }

Source

Posted by arkgame