zoukankan      html  css  js  c++  java
  • java多线程学习-java.util.concurrent详解(三) Semaphore

    转载于:http://janeky.iteye.com/blog/769965

    我们先来学习一下JDK1.5 API中关于这个类的详细介绍: 
    “一个计数信号量。从概念上讲,信号量维护了一个许可集。如有必要,在许可可用前会阻塞每一个 acquire(),然后再获取该许可。每个 release() 添加一个许可,从而可能释放一个正在阻塞的获取者。但是,不使用实际的许可对象,Semaphore 只对可用许可的号码进行计数,并采取相应的行动。” 

        我们一般用它来控制某个对象的线程访问对象 

        例如,对于某个容器,我们规定,最多只能容纳n个线程同时操作 
    使用信号量来模拟实现 

    package com.winterbe.java8.samples.concurrent;
    
    import java.util.Collections;
    import java.util.HashSet;
    import java.util.Random;
    import java.util.Set;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Semaphore;
    /*
     * Semaphore通常用于对象池的控制 
     * */
    public class TestSemaphore {
    
    	public static void main(String[] args) throws InterruptedException {
    		ExecutorService exec = Executors.newCachedThreadPool();
    		TestSemaphore t = new TestSemaphore();
    		final BoundedHashSet<String> set = t.getSet();
            final int MAX=10;
    		for (int i = 0; i < MAX; i++) {// 十个线程同时操作add
    			exec.execute(new Runnable() {
    				public void run() {
    					try {
    						set.deal(Thread.currentThread().getName());
    					} catch (InterruptedException e) {
    						e.printStackTrace();
    					}
    				}
    			});
    		}		 
    		exec.shutdown();
    	}
    
    	public BoundedHashSet<String> getSet() {
    		return new BoundedHashSet<String>(2);// 定义一个边界约束为2的线程
    	}
    
    	class BoundedHashSet<T> {
    		private final Set<T> set;
    		private final Semaphore semaphore;
    		final Random random = new Random();
    
    		public BoundedHashSet(int bound) {
    			this.set = Collections.synchronizedSet(new HashSet<T>());
    			this.semaphore = new Semaphore(bound, true);
    		}
    
    		public void deal(T o) throws InterruptedException {
    		    System.out.println("availablePermits:"+semaphore.availablePermits());
    			semaphore.acquire();// 信号量控制可访问的线程数目,如果访问的数量达到Bount,则阻塞
    			set.add(o);
    			System.out.printf("add:%s%n", o);
    			Thread.sleep(random.nextInt(1000));//Sleep 一定时间后,师傅信号量,这里也就是业务逻辑处理的时间
    			semaphore.release();// 释放掉信号量
    			System.out.printf("remove:%s%n", o);
    
    		}
     
    	}
    }
    

         总结:Semaphore通常用于对象池的控制 

  • 相关阅读:
    BootstrapBlazor 组件库介绍
    BootstrapBlazor 组件库使用体验---Table篇
    【转载】Bootstrap Blazor 组件介绍 Table (一)自动生成列功能介绍
    【转载】Bootstrap Blazor 组件介绍 Table (二)自定义模板列功能介绍
    【转载】Bootstrap Blazor 组件介绍 Table (三)列数据格式功能介绍
    使用acme.sh从Let's Encrypt申请SSL证书
    Docker一些基本操作
    Nginx配置https以及配置说明
    vi操作
    CentOS 7下安装Docker
  • 原文地址:https://www.cnblogs.com/fanxiaojun/p/4914508.html
Copyright © 2011-2022 走看看