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

小鱼儿 2022-08-12 13:29 15阅读 0赞

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

当一个线程想要访问某个共享资源，首先，它必须获得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时，则会选择时间等待最久的一个进入。

参考：

[并发网][Link 1]

[老紫竹并发学习][Link 2]

[Link 1]: http://ifeve.com/thread-synchronization-utilities-2/
[Link 2]: http://blog.csdn.net/java2000_net/article/details/3997449