请java大拿们看看,线程池的一个疑惑问题,关于任务队列的几个为什么....
先上代码,从网上得来的,贴一下主要部分:
public final class ThreadPool
{
private static List<Task> taskQueue = Collections.synchronizedList(new LinkedList<Task>());
private ThreadPool()
{
workers = new PoolWorker[5];
for (int i = 0; i < workers.length; i++)
{
workers[i] = new PoolWorker(i);// 在线程池里生成多个线程并且全部进入启动状态
}
}
....
public void batchAddTask(Task[] taskes)
{
synchronized (taskQueue)
{
for (int i = 0; i < taskes.length; i++)
{
taskes[i].setTaskId(++taskCounter);
taskQueue.add(taskes[i]);
}
/* 唤醒队列, 开始执行 */
taskQueue.notifyAll();
}
private class PoolWorker extends Thread
{
public void run()
{
while (isRunning)
{
Task r = null;
synchronized (taskQueue)// 加synchronized的作用是避免几个线程同时执行一个task
{
while (taskQueue.isEmpty())
{
try
{
taskQueue.wait(20);
}
catch (Exception ie)
{
}
}
r = (Task) taskQueue.remove(0);
}
}
}
我不明白的地方是对于代码
while (taskQueue.isEmpty())
{
try
{
taskQueue.wait(20);
}
这一段,意思就是只要队列taskQueue为空就循环等待,我不明白为什么要加这个等待,只要为空就一直循环不就行了,之后不为空了应该自动跳出循环直接执行r = (Task) taskQueue.remove(0);不就完了吗...可是我把taskQueue.wait(20);去了后 ,循环一直退不出来,就是说一直没办法执行到 r = (Task) taskQueue.remove(0);语句....
后来我认为是上面这段代码有问题
taskQueue.notifyAll();
因为当时觉得,队列赋值了就可以用了,还通知什么,就把这段也去了,结果
while (taskQueue.isEmpty())
{
try
{
}
这个循环还是没完没了...
但是把这两段代码都加上就没有问题,程序可以正常运行,请高手指点,为什么会这样?为什么有了taskQueue.notifyAll();和 taskQueue.wait(20);程序就能正常运行呢?
------解决方案--------------------注意一点,while是在同步块中,如果没有wait的话,就不会释放锁,那么就不能把任务加入队列,所以队列一直是空,所以就一直循环了。
这个是同步的问题,你没能理解。
另外,wait除了释放锁之外还有降低cpu开销的意图。
------解决方案--------------------
------解决方案--------------------
你自己实现线程池啊?我劝你不要这么做哦!
JDK 1.5 开始有 ThreadPoolExecutor 类了,没有必要再去自己实现了。一个线程池的实现非常复杂,普通开发人员根本不可能完成。
涉及到“池”的东西,不管是实例池、数据库连接池,还是线程池,他们的实现都是极其复杂的。如果不是精于这些东西的话,要想实现并且能运用在实际中,那就是不可能的任务。
线程池的实现,我粗粗地列举了一下,以如下技术难点:
1:如果不是使用 java.util.concurrent.LinkedBlockingQueue 的话,那就需要自行实现一个阻塞的有界或者无界队列,用于存放等待的任务
2:线程池中的线程在运行时产生异常且处理不当,这时将会产生线程泄漏,也就是说线程池中的线程少了一个。一个可用的线程池在监测到这种情况出现时应该回收该泄漏的线程,并及时补充一个新的线程
3:线程池中的线程都在工作时,若还有任务加入进来,这时需要将其放入到队列之中,若池中的某个线程工作完了,需要及时通知队列中的任务附加到可用线程中去执行
-----------------------------------
线程池基本上是这样实现的:
1:先 new 出固定数量的 Thread,类似于这样:Thread t0 = new Thread(new WorkRunnable());
WorkRunnable 的结构基本上是这样的(实际远远比这复杂):
Java code
public class WorkRunnable implements Runnable {
private Runnable command;
public WorkRunnable(Runnable command) {
this.command = command;
}
public void run() {
command.run();
}
public void setCommand(Runnable command) {
this.command = command;
}
}