4

我想了解线程池的逻辑，下面有一个简单的不正确且不完整的实现：

class ThreadPool {
    private BlockingQueue<Runnable> taskQueue;

    public ThreadPool(int numberOfThreads) {
        taskQueue = new LinkedBlockingQueue<Runnable>(10);

        for (int i = 0; i < numberOfThreads; i++) {
            new PoolThread(taskQueue).start();
        }
    }

    public void execute(Runnable task) throws InterruptedException {
        taskQueue.put(task);
    }
}


class PoolThread extends Thread {
    private BlockingQueue<Runnable> taskQueue;

    public PoolThread(BlockingQueue<Runnable> queue) {
        taskQueue = queue;
    }

    public void run() {
        while (true) {
            try {
                taskQueue.take().run();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

如果要执行的线程数超过了taskQueue的大小，调用线程会被阻塞吗？ThreadPoolExecutor - 在这里我们可以看到，在这种情况下，它是一个拒绝执行处理程序的工作，但我仍然无法理解它是如何工作的。提前感谢您的帮助。

编辑：

将阻塞队列的最大大小设置为 10

4

2 回答 2

5

想象一群砌砖工（你的线程）正在建造一堵墙，还有一堆砖头（你的 BlockingQueue）。

每个瓦工从堆中取出一块砖，定位它，然后挑选另一个（taskQueue.take（）） - 直到堆中有砖，瓦工保持忙碌。

一辆卡车不时到达，用更多的砖填满堆 - 但堆上只有有限的空间，如果没有空间，卡车就会停下来等待砖匠用完足够的砖。

只要堆里有足够的砖块（超过砌砖工的数量），您就可以放心，所有砌砖工都会有足够的工作量 - 但是当堆开始变空时，砌砖工将不得不停止工作，直到交付新砖块。

您必须选择合适数量的砌砖工，数量少，卡车会经常在堆中等待空间，太多，他们中的大多数会闲置等待新砖。

在实现方面，一般来说，Java 为您提供了一个线程池，您很少创建自己的 -

 ExecutorService threadExecutor = Executors.newFixedThreadPool( 3 );

然后你打电话：

threadExecutor.submit(Runnable...);

将任务添加到队列中。

于 2012-11-04T19:56:14.560 回答
4

如果要执行的线程数超过了taskQueue的大小，调用线程会被阻塞吗？

队列的大小是未运行的任务数。通常，即使线程很忙，它也会为空。拥有与线程数匹配的队列长度没有意义，此时也没有什么特别的事情发生。

在这里我们可以看到，在这种情况下，它是被拒绝执行处理程序的工作

仅当队列已满时才调用拒绝处理程序。您的队列没有限制，因此即使您支持此功能也不会调用它。

但是，如果它确实有限制并且支持此功能，则典型行为是抛出异常。你可以让它做其他事情，比如阻塞，让当前线程运行任务（这是我的偏好）或忽略任务。

我仍然无法理解它是如何工作的。

当您将任务提供（）到队列时，如果队列不能接受它，它将返回 false。发生这种情况时，调用被拒绝的执行处理程序。

于 2012-11-04T10:30:36.480 回答