当前位置：首页 -> AI编程基础 -> JAVA

java编写线程连接池代码

2014-11-23 23:34:37 · 作者: · 浏览: 0
标签: java 编写 线程 连接 代码
java编写线程连接池代码如下：
  1. 线程池:
  2. import java.util.LinkedList;
  4. public abstract class Manager {
  6. private String mThreadPoolName = null;
  8. private int mThreadPoolMaxSize = 1;
  10. private LinkedList workers = new LinkedList();
  12. public Manager() {
  13. }
  15. public Manager(String name, int poolMaxSize) {
  16. mThreadPoolName = name;
  17. createWorker(name, poolMaxSize);
  18. mThreadPoolMaxSize = poolMaxSize;
  19. }
  21. private void createWorker(int poolMaxSize) {
  22. for (int i = 0; i < poolMaxSize; i ) {
  23. Worker worker = new ...Worker(this);
  24. workers.addLast(worker);
  25. }
  26. }
  28. public synchronized Worker getIdleWorker() {
  29. return (Worker)workers.removeFirst();
  30. }
  32. public synchronized void notifyFree(Worker worker) {
  33. if (workers.size() < mThreadPoolMaxSize) {
  34. workers.addLast(worker);
  35. } else {
  36. worker = null;
  37. }
  38. }
  40. public int getThreadPoolMaxSize() {
  41. return mThreadPoolMaxSize;
  42. }
  44. public void setThreadPoolMaxSize(int threadPoolMaxSize) {
  45. this.mThreadPoolMaxSize = threadPoolMaxSize;
  46. }
  47. }
  49. 线程抽象类
  50. public abstract class Worker implements Runnable {
  52. private Manager mManager = null;
  54. private Thread mThread = null;
  56. public Worker() {
  57. }
  59. public Worker(String threadName, Manager manager) {
  60. mManager = manager;
  61. mThread = new Thread(this, threadName);
  62. init();
  63. &nb