并发编程网 - ifeve.com

声明：本文是《 Java 7 Concurrency Cookbook 》的第一章， 作者： Javier Fernández González 译者：郑玉婷

用线程工厂创建线程

在面向对象编程的世界中，工厂模式是最有用的设计模式。它是一个创造模式，还有它的目的是创建一个或几个类的对象的对象。然后，当我们想创建这些类的对象时，我们使用工厂来代替new操作。

有了这个工厂，我们有这些优势来集中创建对象们：

• 更简单的改变了类的对象创建或者说创建这些对象的方式。
• 更简单的为了限制的资源限制了对象的创建。 例如， 我们只new一个此类型的对象。
• 更简单的生成创建对象的统计数据。

Java提供一个接口， ThreadFactory 接口实现一个线程对象工厂。 并发 API 使用线程工厂来创建线程的一些基本优势。

在这个指南中，我们将学习如何实现ThreadFactory 接口来创建Thread 对象，当我们储存创建的线程对象时，可以取个性化的名字。

准备
指南中的例子是使用Eclipse IDE 来实现的。如果你使用Eclipse 或者其他的IDE，例如NetBeans, 打开并创建一个新的java项目。

怎么做呢…
按照这些步骤来实现下面的例子:

1.   创建一个类名为 MyThreadFactory 一定实现 ThreadFactory 接口。

[code lang=”java”]
public class MyThreadFactory implements ThreadFactory {
[/code]

2.   声明属性们：counter，整数，用来储存线程对象的数量；name，字符串，每个创建线程的名字；stats, 字符串list, 储存创建的线程对象的统计数据。我们也要实现类的构造函数并初始化。

[code lang=”java”]
private int counter;
private String name;
private List<String> stats;
public MyThreadFactory(String name){
counter=0;
this.name=name;
stats=new ArrayList<String>();
}[/code]

3.   实现 newThread() 方法. 此方法 会接收Runnable接口并返回一个 Thread 对象给这个 Runnable 接口。 在这里, 我们生成线程对象的名字，然后创建新的线程对象，最后保存统计数据。

[code lang=”java”]
@Override
public Thread newThread(Runnable r) {
Thread t=new Thread(r,name+"-Thread_"+counter);
counter++;
stats.add(String.format("created thread %d with name %s on %s\n",t.getId(),t.getName(),new Date()));

return t;
}
[/code]

4.   实现 getStatistics()方法 ，返回 String 对象， 全部的创建的 Thread 对象的统计数据。

[code lang=”java”]
public String getStats(){
StringBuffer buffer=new StringBuffer();
Iterator<String> it=stats.iterator();
while (it.hasNext()) {
buffer.append(it.next());
buffer.append("\n");
}
return buffer.toString();
}
[/code]

5.   创建一个类名为 Task 一定实现 Runnable接口. 对于这个例子，这些任务什么都不做只是休眠一秒。

[code lang=”java”]
public class Task implements Runnable {
@Override
public void run() {
try { TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
[/code]

6.   创建主类. 创建一个类名为 Main 并实现main() 方法.

[code lang=”java”]
public class Main {
public static void main(String[] args) {
[/code]

7.   创建 MyThreadFactory 对象和 Task 对象。

[code lang=”java”]
MyThreadFactory factory=new MyThreadFactory("MyThreadFactory");
Task task=new Task();
[/code]

8.   使用 MyThreadFactory 对象创建 10 Thread 对象并开始它们.

[code lang=”java”]
Thread thread;
System.out.printf("Starting the Threads\n");
for (int i=0; i<10; i++){
thread=factory.newThread(task);
thread.start();
}
[/code]

9.   把线程厂的数据写入控制台。

[code language=”java”]
System.out.printf("Factory stats:\n"); System.out.printf("%s\n",factory.getStats());
[/code]

10. 运行例子并查看结果。

它是怎么工作的…

ThreadFactory 接口只有一个方法是 newThread。它接收 Runnable 对象作为参数并返回一个 Thread 对象。当你实现一个 ThreadFactory 接口，你必须实现此接口并覆盖这个方法。最基本的 ThreadFactory只有一行。

[code lang=”java”]
return new Thread(r);
[/code]

你可以加一些变量来提升这个实现：

• 在这个例子中创建自定义线程，名字使用特别形式或者继承Java Thread类来创建自己的Thread类。
• 保存线程创建数据，如之前的例子。
• 限制线程创建个数。
• 验证线程的创建。
• 和你能想到的任何东西。

使用工厂设计模式是很好的练习，但是，如果你实现一个 ThreadFactory 接口来集中创建线程，那么你必须再检查代码确保使用的线程都是用这个工厂创建的。

参见

• 第七章: 并发类的定制：实现ThreadFactory接口来生成自定义线程
• 第七章: 并发类的定制：在执行者对象中使用我们的 ThreadFactory