threadpool.java~13~

手机端游戏开发程序

package chess;

import java.util.*;

public class ThreadPool {
  private Vector UserList;
  private Vector ThreadList;
      public ThreadPool() {
    UserList = new Vector();
    ThreadList = new Vector();
  }

  public int addUser(String username){//插入并返回下标
    UserList.addElement(username);//将此用户加入UserList表中
    ChessCompute cs=new ChessCompute();//为改用户申请一个处理进程
    ThreadList.addElement(cs);//将该进程放入ThreadList表中
    cs.run();//启动该线程
    try {
      cs.wait(); //马上阻塞
    }
    catch (InterruptedException ex) {
    }
    return UserList.size()-1;
  }

  public int getIndex(String un){
    return UserList.indexOf(un);
  }

  public void removeUser(String username){
   int index=this.getIndex(username);
   UserList.removeElementAt(index);
   ThreadList.removeElementAt(index);
  }
  public ChessCompute getThreadAt(int i){
    return  (ChessCompute) ThreadList.elementAt(i);
  }
  public int capacity(){
    return UserList.capacity();
  }
}