threadpool.java

手机端游戏开发程序

package chess;

import java.util.*;

public class ThreadPool
{
  private Vector UserList;
  private Vector ThreadList;

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

  public Vector getUList()
  {
    return UserList;
  }

  public int addUser(String username)
  { //插入并返回下标
    UserList.addElement(username); //将此用户加入UserList表中
    //System.out.println("user表大小:"+UserList.size());
    ChessCompute cs = new ChessCompute(); //为改用户申请一个处理进程
    ThreadList.addElement(cs); //将该进程放入ThreadList表中
    //System.out.println("thread表大小:"+ThreadList.size());
    //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();
  }
}