java中通用的线程池实例代码

1、java中通用的线程池实例代码java中通用的线程池实例代码，需要的朋友可以参考一下代码如下:package com.smart.frame.task.autoTask;import java.util.Collection;import java.util.Vector;/* 任务分发器*/public class TaskManage extends Threadprotected Vector tasks = new Vector();protected boolean running = false;protected boolean stopped = false;protected

2、 boolean paused = false;protected boolean killed = false;private ThreadPool pool;public TaskManage(ThreadPool pool)this.pool = pool;public void putTask(Runnable task)tasks.add(task);public void putTasks(Runnable tasks)for (int i = 0; i tasks.length; i+)this.tasks.add(tasksi);public void putTasks(Col

3、lection tasks)this.tasks.addAll(tasks);protected Runnable popTask()if (tasks.size() 0) return (Runnable) tasks.remove(0);else return null;public boolean isRunning()return running;public void stopTasks()stopped = true;public void stopTasksSync()stopTasks();while (isRunning()trysleep(5)

4、;catch (InterruptedException e)TaskException.getResultMessage(e);public void pauseTasks()paused = true;public void pauseTasksSync()pauseTasks();while (isRunning()trysleep(5);catch (InterruptedException e)TaskException.getResultMessage(e);public void kill()if (!running) interrupt();else killed = true

5、;public void killSync()kill();while (isAlive()trysleep(5);catch (InterruptedException e)TaskException.getResultMessage(e);public synchronized void startTasks()running = true;this.notify();public synchronized void run()trywhile (true)if (!running | tasks.size() = 0)pool.notifyForIdleThread();this.wai

6、t(); elseRunnable task;while (task = popTask() != null)task.run();if (stopped)stopped = false;if (tasks.size() 0)tasks.clear();System.out.println(Thread.currentThread().getId() + : Tasks are stopped);break;if (paused)paused = false;if (tasks.size() 0)System.out.println(Thread.currentThread().getId()

7、 + : Tasks are paused);break;running = false;if (killed)killed = false;break;catch (InterruptedException e)TaskException.getResultMessage(e);return;复制代码 代码如下:package .frame.task.autoTask;import java.util.Collection;import java.util.Iterator;import java.util.Vector;/* 线程池*/

8、public class ThreadPoolprotected int maxPoolSize = TaskConfig.maxPoolSize;protected int initPoolSize = TaskConfig.initPoolSize;protected Vector threads = new Vector();protected boolean initialized = false;protected boolean hasIdleThread = false;public ThreadPool()super();public ThreadPool(int maxPoo

9、lSize, int initPoolSize)this.maxPoolSize = maxPoolSize;this.initPoolSize = initPoolSize;public void init()initialized = true;for (int i = 0; i initPoolSize; i+)TaskManage thread = new TaskManage(this);thread.start();threads.add(thread);public void setMaxPoolSize(int maxPoolSize)this.maxPoolSize = ma

10、xPoolSize;if (maxPoolSize getPoolSize()for (int i = getPoolSize(); i size & i maxPoolSize; i+)TaskManage thread = new TaskManage(this);thread.start();threads.add(thread); else if (size size)TaskManage th = (TaskManage) threads.remove(0);th.kill();public int getPoolSize()return threads.size();protect

11、ed void notifyForIdleThread()hasIdleThread = true;protected boolean waitForIdleThread()hasIdleThread = false;while (!hasIdleThread & getPoolSize() = maxPoolSize)tryThread.sleep(5);catch (InterruptedException e)TaskException.getResultMessage(e);return false;return true;public synchronized TaskManage

12、getIdleThread()while (true)for (Iterator itr = threads.iterator(); itr.hasNext();)TaskManage th = (TaskManage) itr.next();if (!th.isRunning() return th;if (getPoolSize() maxPoolSize)TaskManage thread = new TaskManage(this);thread.start();threads.add(thread);return thread;if (waitForIdleThread() = fa

13、lse) return null;public void processTask(Runnable task)TaskManage th = getIdleThread();if (th != null)th.putTask(task);th.startTasks();public void processTasksInSingleThread(Runnable tasks)TaskManage th = getIdleThread();if (th != null)th.putTasks(tasks);th.startTasks();public void processTasksInSin

14、gleThread(Collection tasks)TaskManage th = getIdleThread();if (th != null)th.putTasks(tasks);th.startTasks();复制代码 代码如下:package com.smart.frame.task.autoTask;public class TopTask implements Runnableprivate ThreadPool pool;public TopTask()super();public TopTask(ThreadPool pool)super();this.pool = pool;Overridepublic void run()init();start();/* 初始化验证权限、参数之类*/publi