Java Stream流式编程用法及说明

import java.util.*;
import java.util.concurrent.*;

/**
 * Java Stream流式编程实战 示例代码
 */
public class Demo {

    public static void main(String[] args) throws Exception {
        // 初始化核心组件
        System.out.println("开始演示：Java Stream流式编程实战");

        // 核心业务逻辑
        List<String> dataList = new ArrayList<>();
        dataList.add("数据项一");
        dataList.add("数据项二");
        dataList.add("数据项三");

        // 使用Stream处理数据
        dataList.stream()
                .filter(item -> item.startsWith("数据"))
                .forEach(item -> System.out.println("处理：" + item));

        System.out.println("演示完成");
    }
}

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class AdvancedService {

    @Transactional(rollbackFor = Exception.class)
    public void processData(List<String> items) {
        // 使用CompletableFuture实现异步处理
        CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
            items.forEach(item -> {
                // 处理每个数据项
                handleItem(item);
            });
        });

        try {
            future.get(30, TimeUnit.SECONDS);
        } catch (Exception e) {
            throw new RuntimeException("数据处理失败", e);
        }
    }

    private void handleItem(String item) {
        System.out.println("处理数据：" + item);
    }
}

// 自定义线程池，避免使用默认配置
ThreadPoolExecutor executor = new ThreadPoolExecutor(
    Runtime.getRuntime().availableProcessors(),      // 核心线程数
    Runtime.getRuntime().availableProcessors() * 2,  // 最大线程数
    60L, TimeUnit.SECONDS,                           // 空闲线程存活时间
    new LinkedBlockingQueue<>(1000),                 // 任务队列容量
    new ThreadPoolExecutor.CallerRunsPolicy()        // 拒绝策略
);