线程与 bufferdReader.readLine

0 0

线程与 bufferdReader.readLine5

有问题请教各位:
利用ThreadPoolExecutor做了一个服务器监听socket端口, 关键代码如下:

        private static final int MAX_POOL_SIZE = 100;

        private static final int CORE_POOL_SIZE = 2;
    
        private static final int KEEPALIVE_TIME = 0;
     
	private static final int QUEUE_CAPACITY = (CORE_POOL_SIZE + MAX_POOL_SIZE) / 2;

	private static final TimeUnit TIME_UNIT = TimeUnit.SECONDS;
	
	public static BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<Runnable>(QUEUE_CAPACITY);

	private static ThreadPoolExecutor pool = new ThreadPoolExecutor(CORE_POOL_SIZE,
			MAX_POOL_SIZE, KEEPALIVE_TIME, TIME_UNIT, workQueue,
			new ThreadPoolExecutor.AbortPolicy());

       /** 如监听到便新建一个服务线程pool.execute(new ServerThread());, 服务线程run()如下 */
	public void run(){
		try{
			try{
                /** First, ask them for their name */
				while (true) {
					/** Send the request message */
					this.send("Please enter a name to chat with.");
					/** Run the method to set it, and if set properly, break from the loop */
					String tmp = input.readLine();
					if (null == tmp || "quit".equals(tmp)) {
						Server.workQueue.remove(this);
						this.close();
					}
					if (null != tmp && this.name(tmp)){
						Server.addDescriptor(this);
						break;
					}
					/** Otherwise, well continue... asking again! */
				}

				/** Now, loop so long as we should be waiting for input, and process */
				while (Server.isClosed == false && this.isClosed == false){
					/** Find our input !!! if one client quit, it keeps on sending null */
					String in = input.readLine(); 
					if (null == in || "quit".equals(in)) {
						Server.removeDescriptor(this);
						Server.workQueue.remove(this);
						this.close();
					}
					/** Process it by sending it to everyone else */
					/** get an iterator of descriptors */
					System.out.println("descriptor: " + Server.descriptorList.size());
					Iterator it = Server.descriptorList.iterator();
					/** Iterate over each one */
					while (it.hasNext() && in != null) {
						/** Pull the descriptor from the iterator */
						Descriptor desc = (Descriptor)it.next();
						/** Send the message */
						desc.send(this.getName() + " says '" + in + "'");
					}
				}
			}
			/** Kill the connection on timeout */
			catch (InterruptedIOException iioe){
				/** Log it */
				System.out.println("Timeout occurred - killing connection to " + this.getName());
				/** Send a message */
				this.send("You vanish in a puff of smoke.");
				/** Logout */
				this.logout();
			}
		}
		/** Catch termination of session so we dont get an error */
		catch (IOException ioe){
			System.out.println(getName() + " has logged out");
			// terminate thread at end of run, automatically
		}
	}

假如核心线程为2, 在cmd里telnet服务端口, 头两个服务开启, 运行至String tmp = input.readLine();等待用户输入.
如果再有一用户, 主服务器执行了pool.execute(new ServerThread(), 并把新的线程放入workQueue(size已增加1)中等待, 其它两个线程一直在String tmp = input.readLine();等待, 并没有执行新线程(因为没有打印出this.send("Please enter a name to chat with.");)

当关闭之前2个socket, 在队列中的第三个线程开始执行, 依旧停留于String tmp = input.readLine()

另问: 服务器如何感知客户那边telnet关闭呢? 我在这里只是根据是否收到null

初涉及线程, 帮忙啦
问题补充：
回复llade:
这个能理解, 就因为核心线程全停留在BufferedReader的readLine方法, 就想在等带输入的时候能空出来处理队列的

2008年6月24日 14:41

sk_Java
10
0 0 0

1个答案按时间排序按投票排序

0 0

线程池中线程的运行顺序是：
corePoolsize达到最大之前(不是maxPoolsize)，新加入线程都属于corePoolsize;
corePoolsize达到最大时，所有新加入线程放入blockingQuery。
当blockingQuery满了，则新加入的线程会导致线程池的线程增加，直到maxPoolsize.
当达到maxPoolsize的时候，则调用RejectExecutionHandler来处理了。此处是AbortPolicy，表示抛出RejectedExecutionException异常。

所以你加入的第三个线程会一直等待，除非前两个线程有一个运行完毕。

至于，服务器如何感知客户那边telnet关闭，两个办法，一个
一个是接收某个byte后表示结束，通常是EOF。
一个是服务器这边设置个超时。

2008年6月24日 16:15