黑马程序员-Condition条件对象、Semaphore、CyclicBarrier、倒计时门栓 CountDownLatch、Exchanger（实现两个线程之间数据交换

----------------------
<a href="http://www.itheima.com"target="blank">ASP.Net+Unity开发</a>、<a href="http://www.itheima.com"target="blank">.Net培训</a>、期待与您交流！ ----------------------

java.util.concurrent.locks.Condition

(await()     、  signal()、  signalAll  )

区别java.lang.Object

(notifyAll   、 notify、wait)这些方法必须用在synchronized包含的代码中，或是方法，或是代码块。就是说当前线程必须是锁的持有者，否则将会抛出异常。

 

用法实例：

Lock  lock=new ReentrantLock（）；

Condition  con=lock.newCondition();

con.await();

con.signal();

 

Semaphore信号灯

Semaphore信号灯可以维护当前访问自身的线程个数，并提供了同步机制，使用Semphore可以控制同时访问资源的线程个数。

（acquire     release  ,availablePermits）

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

public class SemaphoreDemo {

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
ExecutorService es = Executors.newCachedThreadPool();
final Semaphore sp = new Semaphore(3);
for (int i = 0; i < 10; i++) {
new Thread(new Runnable() {

@Override
public void run() {
// TODO Auto-generated method stub
try {
sp.acquire();
System.out.println(Thread.currentThread().getName()
+ "已进入" + "当前有" + (3 - sp.availablePermits())
+ "个线程并发运行");
Thread.sleep(20);
System.out.println(Thread.currentThread().getName()
+ "准备退出");
sp.release();
System.out.println(Thread.currentThread().getName()
+ "已退出" + "当前有" + (3 - sp.availablePermits())
+ "个线程并发运行");
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}).start();
}

}

}

CyclicBarrier 障栅

当一个线程完成了它的那部分任务后，我们让他运行到障栅处，一旦所有的线程都到达了这个障栅，障栅就撤销，线程可以继续运行。

CyclicBarrier  barrier=new CyclicBarrier();

Public void run()

{

  doWork();

Barrier.await();

}

 


 

 

---------------------- <a href="http://www.itheima.com"target="blank">ASP.Net+Unity开发</a>、<a href="http://www.itheima.com"target="blank">.Net培训</a>、期待与您交流！
----------------------