线程联合join

/**
 * ThreadJoin.java
 * cn.com.songjy.test.socket.thread
 * Function： TODO 
 *
 *   version    date      author
 * ──────────────────────────────────
 *   	1.0	 2013-8-16    songjy
 *
 * Copyright (c) 2013, TNT All Rights Reserved.
*/

package cn.com.songjy.test.socket.thread;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/**
 * ClassName:ThreadJoin 
 * 
 * 线程联合
 * 
 * 一个线程A在占有CPU资源期间，可以让其他线程调用join()和本线程联合，如
 * B.join();
 * 称线程A在运行期间联合了线程B。如果线程A在占有CPU资源期间一旦联合线程B，
 * 那么线程A将立刻中断执行，一直等到它联合的线程B执行完毕，线程A再重新排队等待CPU资源，
 * 以便恢复执行。如果线程A准备联合的线程B已经结束，那么B.join()不会产生任何效果。
 * 
 * 顾客只有等待电脑制造厂生产出电脑才能购买
 * @author   songjy
 * @version  1.0
 * @since    v1.0
 * @Date	 2013-8-16	下午3:18:17
 */

public class ThreadJoin implements Runnable {
	
	public static void main(String[] args) {
		ThreadJoin j = new ThreadJoin();
		j.customer.start();
		j.maker.start();
	}
	
	private static Log log = LogFactory.getLog(ThreadJoin.class);

	Computer c;
	
	Thread maker;
	Thread customer;
	
	ThreadJoin(){
		maker = new Thread(this);
		customer = new Thread(this);
		
		maker.setName("电脑制造厂");
		customer.setName("顾客");
		
		
	}
	
	@Override
	public void run() {
		if(Thread.currentThread() == customer) {
			log.info(customer.getName() + "等" + maker.getName() + "生产电脑");
			try {
				maker.join();//线程customer开始等待maker结束
				log.info(customer.getName() + "买了一台电脑："+ c.name +"，价格：" +c.price);
			} catch (InterruptedException e) {
				log.error(e.getMessage(), e);
			}
		} else if (Thread.currentThread() == maker) {
			log.info(maker.getName() + "开始生产电脑，请等待。。。。。。");
			try {
				Thread.sleep(2 * 1000l);
				//maker.sleep(2 * 1000l);//也可,简单明了
			} catch (InterruptedException e) {
				log.error(e.getMessage(), e);
			}
			
			c = new Computer("联想一体机", 4500.0f);
			
			log.info(maker.getName() + "生产完毕！");
		}
	}

	class Computer {
		String name;
		float price;
		Computer(String name, float price){
			this.name = name;
			this.price = price;
		}
	}
}