遇到一个线程方法体生命周期的问题,虽然开始用Thread 的原生类可以很好的解决着个问题,但是总觉的应该用相关的锁可以解决这总问题, 问题如下:
我门用运行一个方法时,有可能需要线程来做这件事情,但是却不知道他们什么时候运行完毕,用Thread.sleep()可以阻塞住,但是这样效率会限制在Thread sleep的interval 内,而且有可能死循环,代码如下:
/**
*
* @author zx04741
*/
public class test {
//private static Semaphore sem = new Semaphore(1);
public static void test1() {
try {
MyThread t = new MyThread();
t.start();
while (!t.over) {
Thread.sleep(100);
}
MyThread t1 = new MyThread();
t1.start();
while (!t1.over) {
Thread.sleep(100);
}
} catch (InterruptedException ex) {
Logger.getLogger(test.class.getName()).log(Level.SEVERE, null, ex);
}
}
static class MyThread extends Thread {
private static int GO = 0;
public volatile static boolean over=false;
public void run() {
try {
//sem.acquire();
over=false;
System.out.println(Thread.currentThread().getId() + ",val:" + (++GO));
Thread.sleep(3000);
over=true;
//sem.release();
} catch (InterruptedException ex) {
Logger.getLogger(test.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
public static void main(String args[]) {
test1();
}
}
信号量的的解释:
一个计数信号量。从概念上讲,信号量维护了一个许可集合。如有必要,在许可可用前会阻塞每一个 acquire()
,然后再获取该许可。每个 release()
添加一个许可,从而可能释放一个正在阻塞的获取者。但是,不使用实际的许可对象,Semaphore 只对可用许可的号码进行计数,并采取相应的行动。
Semaphore 通常用于限制可以访问某些资源(物理或逻辑的)的线程数目。
获得一项前,每个线程必须从信号量获取许可,从而保证可以使用该项。该线程结束后,将项返回到池中并将许可返回到该信号量,从而允许其他线程获取该项。注意,调用 acquire()
时无法保持同步锁定,因为这会阻止将项返回到池中。信号量封装所需的同步,以限制对池的访问,这同维持该池本身一致性所需的同步是分开的。
我们在这里只要一个限制访问就可以了,代码改后如下:
/**
*
* @author zx04741
*/
public class test {
private static Semaphore sem = new Semaphore(1);
public static void test1() {
MyThread t = new MyThread();
t.start();
MyThread t1 = new MyThread();
t1.start();
}
static class MyThread extends Thread {
private static int GO = 0;
public void run() {
try {
sem.acquire();
System.out.println(Thread.currentThread().getId() + ",val:" + (++GO));
Thread.sleep(3000);
sem.release();
} catch (InterruptedException ex) {
Logger.getLogger(test.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
public static void main(String args[]) {
test1();
}
其实信号量会用在我门的一些IDE里面,我们在调试程序的时候设置断点应该就这种锁机制, 和MFC 里面的CSemaphore应该是一样的底层, 应该是属于互斥MUTEX的...
分享到:
相关推荐
资源包含了vxworks多任务(task和semaphore信号量及事件)的相关编程例子,通过创建多任务的简单例子,帮助大家了解taskSpawn函数、信号量semaphore、以及事件event的使用方法。
Semaphore是计数信号量。Semaphore管理一系列许可证。每个acquire方法阻塞,直到有一个许可证可以获得然后拿走一个许可证;每个release方法增加一个许可证,这可能会释放一个阻塞的acquire方法。然而,其实并没有...
一.semaphore信号量原理 多线程同时运行,能提高程序的运行效率,但是并非线程越多越好,而semaphore信号量可以通过内置计数器来控制同时运行线程的数量,启动线程(消耗信号量)内置计数器会自动减一,线程结束(释放...
使用信号量(Semaphore)实现线程的同步
信号量(Semaphore)是一种实现任务间通信的机制,可以实现任务之间同步或临界资源的互斥访问 (临界资源指同一时刻只能有有限个访问),常用于协助一组相互竞争的任务来访问临界资源。运行机制可以理解为:信号量是...
Laravel开发-laravel-semaphore 信号量集成到Laravel的通知层。
信号量(Semaphore)哲学家进餐问题(the dining philosophers problem)---------------------------程序
异步信号量 基于 Java 的并发信号量的计数信号量。 安装 通过 npm 安装模块: npm install async-semaphore 快速示例 // fairness false var Semaphore = require ( 'async-semaphore' ) ; var semaphore = new ...
难堪的一次面试: 信号量Semaphore了解过吗?没有
介绍临界资源的访问机制,有Semaphore,signal,mutex等
主要介绍了Java中Semaphore(信号量)的使用方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
信号量在go语言上实现几种信号量模式。例子基本信号量BasicSemaphore是一个管理固定数量的并发任务的信号灯。 func TestSemaphore ( t * testing. T ) { permit := 3 sem := semaphore . NewSemaphore ( permit ) ...
从0.8.6版本开始,bordeaux-threads有其自己的内置信号量,因此您绝对应该使用它代替bt-semaphore。 安装 bt-semaphore可通过。 如果您好奇,还可以克隆Git存储库: cd ~/quicklisp/local-projects git clone ...
主要介绍了Java并发编程Semaphore计数信号量详解,具有一定参考价值,需要的朋友可以了解下。
关于Android变成中的信号量semaphore,在使用过程中我们往往搞不清楚其信号量的申请和使用。这里主要针对信号量初始值为零的情况做介绍,其他情况不做讨论。初始值为零的情况较少使用,部分代码中的这个情况往往让...
1、信号量:就是一种可用来控制访问资源的数量的标识,设定了一个信 2、信号量主要有3个函数,分别是: 3、那么就开头提的问题,我们用代码来解决
释放信号量_tx_semaphore_put 1,如果tx_semaphore_suspension_list挂起队列为空,那么直接把tx_semaphore_count计数器加一 2,如果tx_semaphore_suspension_list挂起队列不为空,那么tx_semaphore_suspension_list...
JAVA多线程--信号量(Semaphore)_.docx
信号 基于CAS的可快速调整大小的golang信号量允许加权获取/释放; 支持通过上下文取消; 创建后允许更改信号量限制; 比基于通道的信号量更快。用法发起import "github....
信号量本质上是一个非负的整数计数器,它被用来控制对公共资源的访问。当公共资源增加时,调用函数sem_post()增加信号量。只有当信号量值大于0时,才能使用公共资源,使用后,函数sem_wait()减少信号量。函数...