package multhread;



import java.io.BufferedInputStream;

import java.io.DataInputStream;

import java.io.IOException;

import java.io.OutputStream;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.concurrent.Executors;

import java.util.concurrent.ExecutorService;



public class ThreadPoolTest {



	public static void main(String[] args)

	{

		boolean flag = true;

		

		try

		{

			//1,创建线程池

			ExecutorService pool = Executors.newFixedThreadPool(10);

			

			//2,创建服务器

			ServerSocket server = new ServerSocket(12345);

			

			System.out.println("开始监听");

			

			

			while(flag)

			{

				//这里flag一直为真，也就是说这个程序会一直在这里循环

				//不断的接受来到的信息??? 是如此么？？？

				Socket socket = server.accept();

				//execute之后，这个线程会运行么？

				//我没有看到start，也没看到关闭.如果这样，进入了10个线程，那么这个线程池

				//是不是就满了，无法再使用。

				pool.execute(new ServerThread(socket));

			}

			//既然在flag里进行无限制的循环，那么这里的操作永远不会达到，还有意义么？

			//难道在新的线程里，能够修改这个flag的值？？让程序退出么 ？

			server.close();

			pool.shutdown();

		}

		catch(IOException e)

		{

			e.printStackTrace();

		}

		

	}

}



class ServerThread implements Runnable

{

	private Socket socket = null;

	

	ServerThread(Socket socket)

	{

		this.socket = socket;

	}

	public void run()

	{

		try

		{

			//客户端输入输出流

			DataInputStream is = new DataInputStream

					(new BufferedInputStream(socket.getInputStream()));

			

			OutputStream os = socket.getOutputStream();

			

			String inputLine;

			

			//4， readLine() 为何会显示过时？？？

			while((inputLine = is.readLine()) != null)

			{

				//输入bye的时候关闭连接

				if(inputLine.equals("bye"))

				{

					break;

				}

				else

				{

					System.out.println(inputLine);

					os.write(("reply:" + inputLine).getBytes());

				}

			}

			is.close();

			os.close();

			socket.close();

		}

		catch(IOException e)

		{

			e.printStackTrace();

		}

	}

}