知识大全新特征-信号量

Posted 2022-07-19 资源

篇首语：不飞则已，一飞冲天；不鸣则已，一鸣惊人。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全新特征-信号量相关的知识，希望对你有一定的参考价值。

Java线程：新特征-信号量 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

Java的信号量实际上是一个功能完毕的计数器对控制一定资源的消费与回收有着很重要的意义信号量常常用于多线程的代码中并能监控有多少数目的线程等待获取资源并且通过信号量可以得知可用资源的数目等等这里总是在强调数目二字但不能指出来有哪些在等待哪些资源可用因此本人认为这个信号量类如果能返回数目还能知道哪些对象在等待哪些资源可使用就非常完美了仅仅拿到这些概括性的数字对精确控制意义不是很大目前还没想到更好的用法下面是一个简单例子 import ncurrent ExecutorService; import ncurrent Executors; import ncurrent Semaphore; /** * Java线程新特征信号量 * * @author leizhimin : : */ public class Test public static void main(String[] args) MyPool myPool = new MyPool( ); //创建线程池 ExecutorService threadPool = Executors newFixedThreadPool( ); MyThread t = new MyThread( 任务A myPool ); MyThread t = new MyThread( 任务B myPool ); MyThread t = new MyThread( 任务C myPool ); //在线程池中执行任务 threadPool execute(t ); threadPool execute(t ); threadPool execute(t ); //关闭池 threadPool shutdown(); /** * 一个池 */ class MyPool private Semaphore sp; //池相关的信号量 /** * 池的大小这个大小会传递给信号量 * * @param size 池的大小 */ MyPool(int size) this sp = new Semaphore(size); public Semaphore getSp() return sp; public void setSp(Semaphore sp) this sp = sp; class MyThread extends Thread private String threadname; //线程的名称 private MyPool pool; //自定义池 private int x; //申请信号量的大小 MyThread(String threadname MyPool pool int x) this threadname = threadname; this pool = pool; this x = x; public void run() try //从此信号量获取给定数目的许可 pool getSp() acquire(x); //todo 也许这里可以做更复杂的业务 System out println(threadname + 成功获取了 + x + 个许可！ ); catch (InterruptedException e) e printStackTrace(); finally //释放给定数目的许可将其返回到信号量 pool getSp() release(x); System out println(threadname + 释放了 + x + 个许可！ ); 任务B成功获取了个许可！任务B释放了个许可！任务A成功获取了个许可！任务C成功获取了个许可！任务C释放了个许可！任务A释放了个许可！ Process finished with exit code 从结果可以看出信号量仅仅是对池资源进行监控但不保证线程的安全因此在使用时候应该自己控制线程的安全访问池资源 cha138/Article/program/Java/hx/201311/26264

知识大全 新特征-信号量

知识大全新特征-信号量