Java Stream流式处理技巧

这个话题之前一直想整理，今天终于抽出时间来写。本文尽量用实际代码说话，避免空谈概念。

先搞清楚原理

要理解Java，先得搞清楚编译与运行时这个机制。直接看代码比看文字描述来得快：

from functools import lru_cache
import time

@lru_cache(maxsize=128)
def fibonacci(n: int) -> int:
    if n <= 1:
        return n
    return fibonacci(n - 1) + fibonacci(n - 2)

start = time.time()
result = fibonacci(35)
elapsed = time.time() - start
print(f'fib(35) = {result}, 耗时: {elapsed:.4f}s')
print(f'缓存信息: {fibonacci.cache_info()}')

# 装饰器模式
def timer(func):
    def wrapper(*args, **kwargs):
        start = time.time()
        result = func(*args, **kwargs)
        elapsed = time.time() - start
        print(f'{func.__name__} 耗时: {elapsed:.4f}s')
        return result
    return wrapper

@timer
def slow_function():
    time.sleep(0.1)
    return 'done'

slow_function()

实际怎么用

实际用的时候有几个注意点。首先是配置问题，不同环境参数可能不一样。其次是性能，数据量大的时候要注意包管理。看这段实际运行的代码：

from abc import ABC, abstractmethod
from typing import List, Callable

class ObserverPattern:
    pass

class EventManager:
    def __init__(self):
        self._listeners: dict = {}

    def subscribe(self, event_type: str, listener: Callable):
        if event_type not in self._listeners:
            self._listeners[event_type] = []
        self._listeners[event_type].append(listener)

    def unsubscribe(self, event_type: str, listener: Callable):
        if event_type in self._listeners:
            self._listeners[event_type].remove(listener)

    def notify(self, event_type: str, data: dict):
        for listener in self._listeners.get(event_type, []):
            listener(data)

manager = EventManager()
manager.subscribe('user_login', lambda d: print(f'用户 {d["name"]} 已登录'))
manager.notify('user_login', {'name': 'Alice'})

进阶一点的用法

有些场景下Java的常规写法不够用，需要做包管理。这个改动涉及的地方不多，但要注意顺序：

容易踩的坑

踩坑经验分享：Java在编译与运行时方面有几个暗坑。最常见的是参数默认值不符合预期，其次是并发场景下的竞态条件。建议加上防御性检查。

写在最后

Java这块先整理到这里。包管理是最重要的部分，务必理解透彻。如果遇到问题，先检查配置和版本，大部分报错都是这两个原因。