Java并发学习之十六——线程同步工具之信号量(Semaphores)

时间:2021-10-29 14:45:12

本文是学习网络上的文章时的总结,感谢大家无私的分享。

当一个线程想要访问某个共享资源,首先,它必须获得semaphore。如果semaphore的内部计数器的值大于0,那么semaphore减少计数器的值并允许访问共享的资源。计数器的值大于0表示,有可以*使用的资源,所以线程可以访问并使用它们。

package chapter3;

import java.util.concurrent.Semaphore;

public class PrintQueue2 {
private final Semaphore semaphore;
public PrintQueue2(){
semaphore = new Semaphore(1);

}
public void printJob(Object document){

try {
semaphore.acquire();
long duration = (long)(Math.random()*10);
System.out.println(Thread.currentThread().getName()+" PrintQueue "+duration
);
} catch (InterruptedException e) {
e.printStackTrace();

}finally{
semaphore.release();
}
}
}

package chapter3;

public class Job implements Runnable{
private PrintQueue2 printQueue;
public Job(PrintQueue2 printQueue){
this.printQueue = printQueue;
}

@Override
public void run() {
System.out.printf("%s:Going to print a job\n",
Thread.currentThread().getName());
printQueue.printJob(new Object());
System.out.printf("%s: The document has been printed\n",Thread.currentThread().getName());
}
}

package chapter3;

public class Main {

/**
* <p>
* </p>
* @author zhangjunshuai
* @date 2014-9-23 下午8:45:31
* @param args
*/
public static void main(String[] args) {
PrintQueue2 printQueue = new PrintQueue2();
Thread thread[] = new Thread[10];
for(int i=0;i<10;i++){
thread[i] = new Thread(new Job(printQueue),"Thread"+i);
}

for(int i=0;i<10;i++){
thread[i].start();
}
}

}

可修改Semaphores的公平性,在默认的情况下信号量的进入是不公平的。如果在初始化的第二个参数设定为true时,则会选择时间等待最久的一个进入。

参考:

并发网

老紫竹并发学习