serverthreadmanager.java

3G体验手机展示程序 3G体验手机展示程序 3G体验手机展示程序

package com.hongguan.lifeshowclient2;

import java.net.*;
import java.util.*;

/**
 * 本类负责创建和管理手机客户端的socket连接线程；
 * @author Administrator
 *
 */
public class ServerThreadManager {
	private static ServerThreadManager mcm;
	private Hashtable mobileClientArray=new Hashtable(); //Hashtable用来存放线程对象，模拟线程池
	public static synchronized ServerThreadManager getInstance() {
		if(mcm==null){
			mcm = new ServerThreadManager();
		}
		return mcm;
	}

	/**
	 * 本方法实现通过IP从线程池中取出对应的线程
	 * @param ip
	 * @return
	 */
	public ServerThread getMobileClient(String ip){
		java.util.Enumeration em = mobileClientArray.keys();  
		while(em.hasMoreElements())   {  
			Object o = em.nextElement();
			System.out.println(mobileClientArray.get(o)==null);  
		}
		if(ip==null){
			return null;
		}
		return (ServerThread)mobileClientArray.get(ip);
	}

	/**
	 * 本方法将客户端IP对应的线程放入线程池中
	 * @param ip
	 * @param server_thread
	 * @return
	 */
	public boolean addServerThread(String ip,ServerThread server_thread){
		mobileClientArray.put(ip, server_thread);
		return true;
	}
}