如题,系统需要一个线程池,在多处地方均可使用,考虑使用单例来保证线程池对象的唯一性。而单例实现手段目前最火的是枚举,那好吧,就用它了。直接看代码吧:

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

/**
 * 枚举单例
 */
public enum ThreadPool {
    INSTANCE;

    // 线程池单例
    private final ExecutorService es;

    // 私有构造器
    private ThreadPool() {
        es = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() + 1);
    }

    // 公有方法
    public ExecutorService getInstance() {
        return es;
    }
}

  超级简单,使用这个单例也超级简单:

ThreadPool.INSTANCE.getInstance().execute(() -> {
                for (int i = 0; i < order4Items.size(); i++) {
                    String orderId = order4Items.get(i);
                    saveOrderItems(orderId, merchant);

                    // 当请求数达到30或者30的倍数,等一分钟后再次请求
                    if ((i + 1) % 30 == 0) {
                        try {
                            Thread.sleep(60 * 1000);
                        } catch (InterruptedException e) {
                            LOGGER.error("--saveOrders-- error: {}, orderId: {}, sellerId: {}", e.getMessage(), orderId, merchant.getMerchantId());
                            continue;
                        }
                    }
                }
            });
03-24 07:52