CyclicBarrier回环栅栏,相互等待,这样可以阶段性共同完成一个任务,当然希望不要等得太久了,如行走路程,达到同一个阶段,再开始下一个阶段
CountdownLatch 计数器,该线程去等待其他任务的完成,具体是CountdownLatch对象调用await,而countDown则是在要等待的线程实现体中调用,即在任务完成之后调用,表明线程执行完成了!
Semaphore翻译成字面意思为 信号量,Semaphore可以控同时访问的线程个数,通过 acquire() 获取一个许可,如果没有就等待,而 release() 释放一个许可。
Semaphore类它提供了2个构造器:
假若一个工厂有5台机器,但是有8个工人,一台机器同时只能被一个工人使用,只有使用完了,其他工人才能继续使用。那么我们就可以通过Semaphore来实现:
2
3
4
5
6
|
public Semaphore( int permits) { //参数permits表示许可数目,即同时可以允许多少线程进行访问
sync = new NonfairSync(permits);
}
public Semaphore( int permits, boolean fair) { //这个多了一个参数fair表示是否是公平的,即等待时间越久的越先获取许可
sync = (fair)? new FairSync(permits) : new NonfairSync(permits);
}
|
下面说一下Semaphore类中比较重要的几个方法,首先是acquire()、release()方法:
1
2
3
4
|
public void acquire() throws InterruptedException { } //获取一个许可
public void acquire( int permits) throws InterruptedException { } //获取permits个许可
public void release() { } //释放一个许可
public void release( int permits) { } //释放permits个许可
|
acquire()用来获取一个许可,若无许可能够获得,则会一直等待,直到获得许可。
release()用来释放许可。注意,在释放许可之前,必须先获获得许可。
这4个方法都会被阻塞,如果想立即得到执行结果,可以使用下面几个方法:
1
2
3
4
|
public boolean tryAcquire() { }; //尝试获取一个许可,若获取成功,则立即返回true,若获取失败,则立即返回false
public boolean tryAcquire( long timeout, TimeUnit unit) throws InterruptedException { }; //尝试获取一个许可,若在指定的时间内获取成功,则立即返回true,否则则立即返回false
public boolean tryAcquire( int permits) { }; //尝试获取permits个许可,若获取成功,则立即返回true,若获取失败,则立即返回false
public boolean tryAcquire( int permits, long timeout, TimeUnit unit) throws InterruptedException { }; //尝试获取permits个许可,若在指定的时间内获取成功,则立即返回true,否则则立即返回false
|
时间: 2024-10-12 12:28:36