专栏首页后端码事Java并发工具类Semaphore应用实例

Java并发工具类Semaphore应用实例

 1 package com.thread.test.thread;
 2 
 3 import java.util.Random;
 4 import java.util.concurrent.*;
 5 
 6 /**
 7  * Semaphore
 8  * Semaphore维护者一组权限,无实体权限,只是一组代表权限的数字,
 9  * 每一次执行acquire都会被阻塞,直到获取获取权限,
10  * 每一次执行release都会释放权限,唤醒阻塞acquire线程
11  *
12  * Semaphore通常应用于限制资源访问
13  *
14  *
15  * Created by windwant on 2016/5/27.
16  */
17 public class MySemaphore {
18 
19     public static void main(String[] args) {
20         Semaphore sp = new Semaphore(5, true);  //公平性 构造函数 true
21         ExecutorService es = Executors.newCachedThreadPool();
22         Random r = new Random();
23         for (int i = 0; i < 10; i++){
24             es.execute(new Needer(sp, r.nextInt(10), "needer" + i));
25         }
26         es.shutdown();
27     }
28 }
29 
30 class Needer implements Runnable{
31 
32     private Semaphore sp;
33 
34     private int seconds;
35 
36     private String neederName;
37 
38     Needer(Semaphore sp, int seconds, String neederName){
39         this.sp = sp;
40         this.seconds = seconds;
41         this.neederName = neederName;
42     }
43 
44     public void run() {
45         try{
46             sp.acquire();
47             System.out.println("needer " + neederName + " begin, need time: " + seconds + "s");
48             long b = System.currentTimeMillis();
49             for (int i = 0; i < seconds; i++) {
50                 Thread.sleep(1000);
51                 System.out.println("needer: " + neederName + "============" + i + "============");
52             }
53             long d = System.currentTimeMillis() - b;
54             System.out.println("needer " + neederName + " over, executing time: " + TimeUnit.SECONDS.convert(d, TimeUnit.MILLISECONDS));
55             sp.release();
56         } catch (InterruptedException e) {
57             e.printStackTrace();
58         }
59     }
60 }

项目地址:https://github.com/windwant/windwant-demo/tree/master/thread-demo

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • JDK动态代理和CGLIB的区别

    * CGLIB是针对类实现代理,主要是对指定的类生成一个子类,覆盖其中的方法因为是继承,所以该类或方法最好不要声明成final

    WindWant
  • JVM基本结构

    Java堆根据automatic storage management system自动内存管理系统gc的管理方式进行内存划分。一般采用分代收集算法(新生代(E...

    WindWant
  • 怎样才是线程安全的?

    底层其实对应的是用monitorenter及monitorexit字节码指令包裹需要同步的执行。

    WindWant
  • SAP Kyma的environmment和SAP 云平台的Global Account

    SAP Kyma里不同的environment可以导入或新建不同的service:

    Jerry Wang
  • JDK动态代理和CGLIB的区别

    * CGLIB是针对类实现代理,主要是对指定的类生成一个子类,覆盖其中的方法因为是继承,所以该类或方法最好不要声明成final

    WindWant
  • 如何用Power BI获取数据?

    前面我们介绍了Power BI 是什么,今天介绍如何用Power BI 获取数据。

    猴子数据分析
  • 如何用Power BI获取数据?

    前面我们介绍了Power BI 是什么,今天介绍如何用Power BI 获取数据。

    猴子数据分析
  • 使用lyft/ratelimit实现envoy全局限速

    Envoy的全局请求限速服务器,检查是否接受。全局意味着所有代理都将使用一个计数器作为评估请求的基础。每个代理都请求一个上游速率限制服务(在此示例中为Lyfts...

    有点技术
  • DocX在C#中的基本操作方法

        用了一个星期把园子里2016年中有关.net的文章都看了,有些只是大致的看了一下,在看的同时也在记录一些通用的方法。发现有很多对NPOI的文档,主...

    彭泽0902
  • day28 - MD5加密&day-29日志模块

    少年包青菜

扫码关注云+社区

领取腾讯云代金券