知识大全 Java 5.0多线程编程

　　Condition的例子

　　public class Basket      

　　Lock lock = new ReentrantLock();

　　//产生Condition对象

　　Condition produced = lock newCondition();

　　Condition consumed = lock newCondition();

　　boolean available = false;

　　public void produce() throws InterruptedException

　　lock lock();

　　try

　　if(available)

　　consumed await(); //放弃lock进入睡眠 

　　/*生产苹果*/

　　System out println( Apple produced );

　　available = true;

　　produced signal(); //发信号唤醒等待这个Condition的线程

　　 finally

　　lock unlock();

　　public void consume() throws InterruptedException

　　lock lock();

　　try

　　if(!available)

　　produced await();//放弃lock进入睡眠 

　　/*吃苹果*/

　　System out println( Apple consumed );

　　available = false;

　　consumed signal();//发信号唤醒等待这个Condition的线程

　　 finally

　　lock unlock();

　　ConditionTester:

　　public class ConditionTester

　　public static void main(String[] args) throws InterruptedException

　　final Basket basket = new Basket();

　　//定义一个producer

　　Runnable producer = new Runnable()

　　public void run()

　　try

　　basket produce();

　　 catch (InterruptedException ex)

　　ex printStackTrace();

　　;

　　//定义一个consumer

　　Runnable consumer = new Runnable()

　　public void run()

　　try

　　nsume();

　　 catch (InterruptedException ex)

　　ex printStackTrace();

　　;

　　//各产生 个consumer和producer

　　ExecutorService service = Executors newCachedThreadPool();

　　for(int i= ; i < ; i++)

　　service submit(consumer);

　　Thread sleep( );

　　for(int i= ; i< ; i++)

　　service submit(producer);

　　service shutdown();

: Synchronizer 同步装置

　　Java 里新加了 个协调线程间进程的同步装置 它们分别是Semaphore CountDownLatch CyclicBarrier和Exchanger

　　Semaphore:

　　用来管理一个资源池的工具 Semaphore可以看成是个通行证 线程要想从资源池拿到资源必须先拿到通行证 Semaphore提供的通行证数量和资源池的大小一致 如果线程暂时拿不到通行证 线程就会被阻断进入等待状态 以下是一个例子

　　public class Pool

　　ArrayList pool = null;

　　Semaphore pass = null;

　　public Pool(int size)

　　//初始化资源池

　　pool = new ArrayList ();

　　for(int i= ; i

　　pool.add("Resource "+i);

　　//Semaphore的大小和资源池的大小一致

　　pass = new Semaphore(size);

　　public String get() throws InterruptedException

　　//获取通行证,只有得到通行证后才能得到资源

　　pass.acquire();

　　return getResource();

　　public void put(String resource)

　　//归还通行证，并归还资源

　　pass.release();

　　releaseResource(resource);

　　private synchronized String getResource()

　　String result = pool.get(0);

　　pool.remove(0);

　　System.out.println("Give out "+result);

　　return result;

　　private synchronized void releaseResource(String resource)

　　System.out.println("return "+resource);

　　pool.add(resource);

　　SemaphoreTest:

　　public class SemaphoreTest

　　public static void main(String[] args)

　　final Pool aPool = new Pool(2);

　　Runnable worker = new Runnable()

　　public void run()

　　String resource = null;

　　try

　　//取得resource

　　resource = aPool.get();

　　 catch (InterruptedException ex)

　　ex.printStackTrace();

　　//用resource做工作

　　System.out.println("I worked on "+resource);

　　//归还resource

　　aPool.put(resource);

　　;

　　ExecutorService service = Executors.newCachedThreadPool();

　　for(int i=0; i<20; i++)

　　service.submit(worker);

　　service.shutdown();

　　CountDownLatch:

　　CountDownLatch是个计数器，它有一个初始数，等待这个计数器的线程必须等到计数器倒数到零时才可继续。WinGWit比如说一个Server启动时需要初始化4个部件，Server可以同时启动4个线程去初始化这4个部件，然后调用CountDownLatch(4).await()阻断进入等待，每个线程完成任务后会调用一次untDown()来倒计数, 当4个线程都结束时CountDownLatch的计数就会降低为0，此时Server就会被唤醒继续下一步操作。CountDownLatch的方法主要有：