Java线程生命周期管理：理解自动终止与高效任务调度

public Advert saveAdvert(Advert advert) {
    Advert advertToSave = advertRepository.save(advert);

    new Thread(() -> {
        try {
            populateAdvertSearch(advertToSave); // 这是一个耗时操作
        } catch (ParseException | OfficeNotFoundException | OfficePropertyNotFoundException e) {
            e.printStackTrace();
        }
    }).start(); // 每次调用saveAdvert都会创建一个新线程
    return advertToSave;
}

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

@Configuration
public class AppConfig {

    @Bean(destroyMethod = "shutdown") // 确保Spring在应用关闭时调用shutdown
    public ExecutorService taskExecutor() {
        // 创建一个固定大小的线程池，例如10个线程
        // 也可以使用 Executors.newCachedThreadPool() 或 Executors.newWorkStealingPool() 等
        return Executors.newFixedThreadPool(10); 
    }
}

import org.springframework.stereotype.Service;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.CompletableFuture; // 也可以结合CompletableFuture进行更复杂的异步操作

@Service
public class AdvertService {

    private final AdvertRepository advertRepository;
    private final ExecutorService taskExecutor; // 注入线程池

    @Autowired
    public AdvertService(AdvertRepository advertRepository, ExecutorService taskExecutor) {
        this.advertRepository = advertRepository;
        this.taskExecutor = taskExecutor;
    }

    public Advert saveAdvert(Advert advert) {
        Advert advertToSave = advertRepository.save(advert);

        // 将任务提交给线程池
        taskExecutor.submit(() -> {
            try {
                populateAdvertSearch(advertToSave);
            } catch (ParseException | OfficeNotFoundException | OfficePropertyNotFoundException e) {
                e.printStackTrace(); // 记录异常，避免静默失败
                // 考虑更完善的异常处理机制，如发送通知、重试等
            }
        });

        // 如果需要任务执行结果或异常，可以使用 CompletableFuture
        // CompletableFuture.runAsync(() -> { /* 任务 */ }, taskExecutor);

        return advertToSave;
    }

    private void populateAdvertSearch(Advert advert) throws ParseException, OfficeNotFoundException, OfficePropertyNotFoundException {
        // 模拟耗时操作
        System.out.println("Executing populateAdvertSearch for advert: " + advert.getId() + " on thread: " + Thread.currentThread().getName());
        try {
            Thread.sleep(2000); // 模拟2秒钟的耗时
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt(); // 重新设置中断标志
            e.printStackTrace();
        }
        System.out.println("Finished populateAdvertSearch for advert: " + advert.getId());
    }
}