package chat.task;

import java.io.*;
import java.net.*;
import java.util.concurrent.*;

/**
 *Socket接收器
 *用于連續(xù)不斷地將從套接字通道中接收的信息放入一個隊列之中。
 *然后隊列等待用戶取出
 */
public class Receiver extends Thread {
	private Socket socket;
	private BlockingQueue queue;
	private ObjectInputStream in;
	/**
	 * Method ReceiveServicer
	 *
	 *
	 */
	public Receiver(Socket socket,BlockingQueue queue)
													throws IOException{
		this.socket=socket;
		this.queue=queue;
		in=new ObjectInputStream(socket.getInputStream());
	}

	/**
	 * Method run
	 *
	 *
	 */
	public void run(){
		try{
			while(true){
				try{
					Object object=in.readObject();
					queue.put(object);
				}catch(InterruptedException e){
					e.printStackTrace();
				}catch(ClassNotFoundException e){
					e.printStackTrace();
				}
			}
		}catch(IOException e){
		}finally{//當連接斷開之后，不論何各情況，總是將套接字對象本身放入隊列
			try{
				in.close();
				queue.put(socket);
			}catch(Exception e){
				e.printStackTrace();
			}
		}
		
	}	
}