重入锁的好搭档：Condition条件
- Condition 条件与Object 的wait 和Object.notify 方法类似。
- Condition 有如下基本方法：
- await() 方法会使当前献策好难过等待，同时释放当前锁，当其他线程中使用signal() 或者使用signalAll()方法时，线程会重新获得锁并继续执行。或者当被中断的时候也能跳出等待。
- awaitUninterruptibly() 与await类似 但是该方法不会再等待的过程中响应中断。
- singal() 方法用于唤醒 一个等待中的线程。singalAll唤醒所有在等待中的线程。
演示代码如下：
public class ReenterLockCondition implements Runnable {
public static ReentrantLock lock =new ReentrantLock();
public static Condition condtionCondition =lock.newCondition(); //生成一个Condition对象
public void run() {
try {
lock.lock();
condtionCondition.await(); //执行这里的时候要求有相关的重入锁，在调用之后会释放锁
System.out.println("Thread is going on");
} catch (Exception e) {
e.printStackTrace();
}finally {
lock.unlock();
}
}
public static void main(String[] args) throws InterruptedException {
ReenterLockCondition t2=new ReenterLockCondition();
Thread t1=new Thread(t2);
t1.start();
Thread.sleep(2000);
lock.lock();
condtionCondition.signal(); //发出通告 ，并且要求其先获得相关锁。
lock.unlock(); //释放重入锁
}
}
//相关具体更好的代码操作可以看ArrayBlockingQueuel例子中的put方法jdk1.7的
代码执行结果
执行结果
允许多个线程同时访问：信号量
- 信号量为多线程协作提供了更为强大的控制方法，广义的说是对锁的扩展。无论是内部锁synchronized还是重入锁ReentrantLock 。一次都只允许一个线程访问一个资源。而信号量可以指定多个线程同时访问某一个资源。
- 构造方法如下：
- Semaphore(int permits);
- Semaphore(int permits,boolean fair) ; // 第二个参数可以指定时候公平
- 在使用构造信号量的时候要指定准入的信号量的数量。同时可以申请多个许可
public class SemapDemo implements Runnable {
final Semaphore semp =new Semaphore(5);
public void run() {
try {
semp.acquire(); //获取信号量 每次能进来5个线程
Thread.sleep(2000);
System.out.println(Thread.currentThread().getId() + ":done!");
semp.release(); // 如果这里信号量泄露 没有释放 那么会导致进入临界区的线程数量越来越少。直到所有的线程不能再访问
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
//开启20个线程 去访问，会发现是5个线程一组数据
ExecutorService executionn= Executors.newFixedThreadPool(20);
final SemapDemo demo =new SemapDemo();
for(int i=0;i<20;i++) {
executionn.submit(demo);
}
}
}
线程结果
