并发编程网 - ifeve.com

声明：本文是《 Java 7 Concurrency Cookbook 》的第四章，作者： Javier Fernández González     译者：许巧辉     校对：方腾飞，叶磊

执行者执行返回结果的任务

Executor framework的一个优点是你可以并发执行返回结果的任务。Java并发API使用以下两种接口来实现：

• Callable：此接口有一个call()方法。在这个方法中，你必须实现任务的（处理）逻辑。Callable接口是一个参数化的接口。意味着你必须表明call()方法返回的数据类型。
• Future：此接口有一些方法来保证Callable对象结果的获取和管理它的状态。

在这个指南中，你将学习如何实现返回结果的任务，并在执行者中运行它们。
阅读全文

声明：本文是《 Java 7 Concurrency Cookbook 》的第四章，作者： Javier Fernández González     译者：许巧辉     校对：方腾飞，叶磊

创建一个大小固定的线程执行者

当你使用由Executors类的 newCachedThreadPool()方法创建的基本ThreadPoolExecutor，你会有执行者运行在某一时刻的线程数的问题。这个执行者为每个接收到的任务创建一个线程（如果池中没有空闲的线程），所以，如果你提交大量的任务，并且它们有很长的（执行）时间，你会使系统过载和引发应用程序性能不佳的问题。

如果你想要避免这个问题，Executors类提供一个方法来创建大小固定的线程执行者。这个执行者有最大线程数。 如果你提交超过这个最大线程数的任务，这个执行者将不会创建额外的线程，并且剩下的任务将会阻塞，直到执行者有空闲线程。这种行为，保证执行者不会引发应用程序性能不佳的问题。

在这个指南中，你将继续学习怎样创建一个大小固定的线程执行者，然后修改本章第一个示例的实现。
阅读全文

声明：本文是《 Java 7 Concurrency Cookbook 》的第四章，作者： Javier Fernández González     译者：许巧辉     校对：方腾飞

创建一个线程执行者

使用Executor framework的第一步就是创建一个ThreadPoolExecutor类的对象。你可以使用这个类提供的4个构造器或Executors工厂类来 创建ThreadPoolExecutor。一旦有执行者，你就可以提交Runnable或Callable对象给执行者来执行。

在这个指南中，你将会学习如何使用这两种操作来实现一个web服务器的示例，这个web服务器用来处理各种客户端请求。 阅读全文

声明：本文是《 Java 7 Concurrency Cookbook 》的第四章，作者： Javier Fernández González     译者：许巧辉     校对：方腾飞

在这个章节中，我们将覆盖：

• 创建一个线程执行者
• 创建一个大小固定的线程执行者
• 执行者运行带有返回结果的任务
• 运行多个任务并处理第一个结果
• 运行多个任务并处理所有结果
• 执行者延迟运行一个任务
• 执行者周期性地运行一个任务
• 执行者取消一个任务
• 执行者控制一个任务完成
• 执行者分离任务的启动和结果的处理
• 执行者控制被拒绝的任务 阅读全文

在各种并发编程模型中，生产者-消费者模式大概是最常用的了。在实际工作中，对于生产消费的速度，通常需要做一下权衡。通常来说，生产任务的速度要大于消费的速度。一个细节问题是，队列长度，以及如何匹配生产和消费的速度。

一个典型的生产者-消费者模型如下：

在并发环境下利用J.U.C提供的Queue实现可以很方便地保证生产和消费过程中的线程安全。这里需要注意的是，Queue必须设置初始容量，防止生产者生产过快导致队列长度暴涨，最终触发OutOfMemory。 阅读全文