threadpool.java~15~

手机端游戏开发程序

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表中
    Thread cs=new Thread(new ChessCompute());//为改用户申请一个处理进程
    ThreadList.addElement(cs);//将该进程放入ThreadList表中
    cs.start();//启动该线程

      cs.yield(); //马上阻塞


    return UserList.size()-1;
  }


public void wakeup(int i){
  Thread cs=(Thread) ThreadList.elementAt(i);
  cs.notify();
}

public void wait(int i){
  Thread cs=(Thread) ThreadList.elementAt(i);
  cs.yield();
}
  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();
  }
}