分析

• 每个消息一个线程。message可以理解为命令，请求。为每一个请求新分配一个线程，由这个线程来执行处理。
• Thread-Per-Message模式中，请求的委托端和请求的执行端是不同的线程，请求的委托端会告诉请求的执行端线程：这项工作就交给你了

编码

public class MessageHandler {
    private final static Random RANDOM = new Random(System.currentTimeMillis());
    public void request(Message message){
        new Thread(()->{
            String value = message.getValue();
            try {
                Thread.sleep(RANDOM.nextInt(1000));
                System.out.println(Thread.currentThread() + " 处理这个"  + value);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
    }
}

测试：

public class PerThreadClient {
    public static void main(String[] args) {
        final MessageHandler messageHandler = new MessageHandler();
        IntStream.rangeClosed(1, 5)
                .forEach(
                        i -> messageHandler.request(new Message(String.valueOf(i)))
                );


    }
}

结果

Thread[Thread-0,5,main] 处理这个1
Thread[Thread-2,5,main] 处理这个3
Thread[Thread-3,5,main] 处理这个4
Thread[Thread-1,5,main] 处理这个2
Thread[Thread-4,5,main] 处理这个5

• 但是这样会频繁的创建和销毁线程，影响性能
• 所以可以使用线程池

使用线程池

public class MessageHandler {
    private final static Random RANDOM = new Random(System.currentTimeMillis());

    private final static Executor EXECUTOR = Executors.newFixedThreadPool(5);

    public void request(Message message){
        EXECUTOR.execute(()->{
            String value = message.getValue();
            try {
                Thread.sleep(RANDOM.nextInt(1000));
                System.out.println(Thread.currentThread() + " 处理这个"  + value);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
    }
}