Java 多线程模拟员工短信和邮件推送：效率优化与线程池应用

本文将介绍如何使用 Java 多线程技术模拟给多个员工推送短信和邮件的业务流程，并通过线程池优化效率。

1. 基本实现

首先，我们创建 Employee 类来存储员工信息，包括 ID、姓名、手机号码和邮箱地址。然后，分别创建 SmsThread 和 EmailThread 类，实现 Runnable 接口，并在 run() 方法中模拟发送短信和邮件。最后，在 main() 方法中创建员工对象集合，并创建线程并启动，分别给每个员工发送短信和邮件。

import java.util.ArrayList;
import java.util.List;

class Employee {
    private int id;
    private String name;
    private String mobile;
    private String email;

    public Employee(int id, String name, String mobile, String email) {
        this.id = id;
        this.name = name;
        this.mobile = mobile;
        this.email = email;
    }

    // getters and setters
}

class SmsThread implements Runnable {
    private Employee employee;

    public SmsThread(Employee employee) {
        this.employee = employee;
    }

    @Override
    public void run() {
        System.out.println('Sending SMS to ' + employee.getName() + ' at ' + employee.getMobile());
        // 在此处调用运营商接口发送短信
    }
}

class EmailThread implements Runnable {
    private Employee employee;

    public EmailThread(Employee employee) {
        this.employee = employee;
    }

    @Override
    public void run() {
        System.out.println('Sending email to ' + employee.getName() + ' at ' + employee.getEmail());
        // 在此处调用邮箱接口发送邮件
    }
}

public class Main {
    public static void main(String[] args) {
        // 创建员工对象集合
        List<Employee> employees = new ArrayList<>();
        for (int i = 1; i <= 20; i++) {
            employees.add(new Employee(i, 'Employee' + i, 'Mobile' + i, 'Email' + i + '@example.com'));
        }

        // 创建短信和邮件线程并启动
        for (Employee employee : employees) {
            Thread smsThread = new Thread(new SmsThread(employee));
            smsThread.start();

            Thread emailThread = new Thread(new EmailThread(employee));
            emailThread.start();
        }
    }
}

2. 使用线程池优化

在实际应用中，频繁创建和销毁线程会带来较大的性能损耗。为了提高效率，我们可以使用线程池来管理线程。线程池可以重复利用线程，减少线程创建和销毁的开销，从而提高程序的执行效率。

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

class Employee {
    private int id;
    private String name;
    private String mobile;
    private String email;

    public Employee(int id, String name, String mobile, String email) {
        this.id = id;
        this.name = name;
        this.mobile = mobile;
        this.email = email;
    }

    // getters and setters
}

class SmsThread implements Runnable {
    private Employee employee;

    public SmsThread(Employee employee) {
        this.employee = employee;
    }

    @Override
    public void run() {
        System.out.println('Sending SMS to ' + employee.getName() + ' at ' + employee.getMobile());
        // 在此处调用运营商接口发送短信
    }
}

class EmailThread implements Runnable {
    private Employee employee;

    public EmailThread(Employee employee) {
        this.employee = employee;
    }

    @Override
    public void run() {
        System.out.println('Sending email to ' + employee.getName() + ' at ' + employee.getEmail());
        // 在此处调用邮箱接口发送邮件
    }
}

public class Main {
    public static void main(String[] args) {
        // 创建员工对象集合
        List<Employee> employees = new ArrayList<>();
        for (int i = 1; i <= 200; i++) {
            employees.add(new Employee(i, 'Employee' + i, 'Mobile' + i, 'Email' + i + '@example.com'));
        }

        // 创建线程池
        ExecutorService executorService = Executors.newFixedThreadPool(10);

        // 提交短信和邮件任务给线程池
        for (Employee employee : employees) {
            executorService.submit(new SmsThread(employee));
            executorService.submit(new EmailThread(employee));
        }
        
        // 关闭线程池
        executorService.shutdown();
    }
}

在这个程序中，我们使用了 ExecutorService 和 Executors.newFixedThreadPool() 来创建一个固定大小的线程池，大小为 10。然后，我们使用 executorService.submit() 方法将短信和邮件任务提交给线程池执行。最后，我们调用 executorService.shutdown() 关闭线程池。通过使用线程池，可以更高效地管理线程，并且可以重复利用线程，减少线程创建和销毁的开销。

3. 注意事项

在实际业务中，发送短信和邮件往往要调用运营商或邮箱接口，相对效率不高。因此，在程序中，我们仅模拟了发送短信和邮件的操作，并未真正调用接口。在实际开发中，需要根据实际情况选择合适的接口和技术方案，并对代码进行优化，以提高效率。