Thread-Per-Message 模式

0. 描述了什么事？

为每一个请求都分配一个线程。

1. 类的说明，怎么抽象？

2. 程序示例

1. Main.java

package thread.per.message;

public class Main {
    public static void main(String[] args) {
        System.out.println("main BEGIN");
        Host host = new Host();
        host.request(10, 'A');
        host.request(20, 'B');
        host.request(30, 'C');
        System.out.println("main END");
    }
}

2. Host.java

package thread.per.message;

public class Host {
    private final Helper helper = new Helper();

    public void request(int count, char c) {
        System.out.println("\t request(" + count + ", " + c + ")BEGIN");
        // 匿名内部类，创建并启动线程，并且调用 helper 的处理方法
        new Thread() {
            @Override
            public void run() {
                helper.handle(c, count);
            }
        }.start();
        System.out.println("\t request(" + count + ", " + c + ")END");
    }
}

3. Helper.java

package thread.per.message;

public class Helper {
    public void handle(char c, int count) {
        System.out.println("\t\t handle(" + count + ", " + c + ") BEGIN");
        // 进行一些输出操作吧~
        for (int i = 0; i < count; i++) {
            System.out.print(c + " ");
            slowly();
        }
        System.out.println("\t\t handle(" + count + ", " + c + ") END");
    }

    private void slowly() {
        // 用来模拟耗时的操作
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}