如何确保订阅Observable的类被置为null时自动取消订阅以支持GC？

嘿，这个需求挺实际的！默认情况下，RxJava的订阅和你的Helper对象生命周期完全脱节——哪怕把helper置为null，之前的订阅还会继续跑，直到Observable完成或者手动取消。要实现“对象被GC时自动取消订阅”，得把订阅的Disposable和Helper的生命周期绑定起来，下面给你两种可行的方案：

方案1：用Java 9+的Cleaner API（推荐） #

Cleaner是Java官方用来替代老旧Finalizer的安全方案，能在对象被GC回收时自动执行清理逻辑。咱们可以给Helper注册一个Cleaner，让它在对象被回收时自动调用dispose()取消订阅：

import java.lang.ref.Cleaner;
import java.lang.ref.WeakReference;
import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.disposables.Disposable;

static class Helper {
    // 创建全局的Cleaner实例
    private static final Cleaner CLEANER = Cleaner.create();
    // 关联清理动作的实例
    private Cleaner.Cleanable cleanable;
    // 保存订阅后的Disposable，用于后续取消
    private Disposable disposable;

    public Helper() {
        // 初始化时注册清理任务，用WeakReference避免持有Helper强引用
        this.cleanable = CLEANER.register(this, new CleanupTask(new WeakReference<>(this)));
    }

    void subscribeTo(Observable<Object> observable) {
        // 先取消之前的订阅（如果存在）
        if (disposable != null && !disposable.isDisposed()) {
            disposable.dispose();
        }
        // 订阅新Observable并保存Disposable
        disposable = observable.subscribe(someObject -> {
            // 这里写你的业务逻辑
            System.out.println("收到事件：" + someObject);
        });
    }

    // 内部类：执行清理动作的任务
    private static class CleanupTask implements Runnable {
        private final WeakReference<Helper> helperRef;

        public CleanupTask(WeakReference<Helper> helperRef) {
            this.helperRef = helperRef;
        }

        @Override
        public void run() {
            // 从WeakReference获取即将被回收的Helper实例
            Helper helper = helperRef.get();
            if (helper != null && helper.disposable != null && !helper.disposable.isDisposed()) {
                helper.disposable.dispose();
                System.out.println("Helper被GC回收，自动取消订阅");
            }
        }
    }
}

为啥用WeakReference？ #

要是CleanupTask直接持有Helper的强引用，那Helper永远不会被GC回收，自动取消订阅就完全失效了——WeakReference只会在对象没有其他强引用时被GC回收，刚好符合咱们的需求。

方案2：用Finalizer（不推荐，仅兼容旧版Java） #

如果你的项目还在使用Java 8及以下版本，可以用Finalizer（但Java 9+已经把它标记为Deprecated了，因为性能差、执行时机不可控）。它是对象被GC前最后执行的方法，咱们可以在里面取消订阅：

import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.disposables.Disposable;

static class Helper {
    private Disposable disposable;

    void subscribeTo(Observable<Object> observable) {
        disposable = observable.subscribe(someObject -> {
            // 处理业务逻辑
            System.out.println("收到事件：" + someObject);
        });
    }

    @Override
    protected void finalize() throws Throwable {
        try {
            // 在对象被GC前取消订阅
            if (disposable != null && !disposable.isDisposed()) {
                disposable.dispose();
                System.out.println("Finalizer触发，自动取消订阅");
            }
        } finally {
            // 必须调用父类的finalize方法
            super.finalize();
        }
    }
}

重要注意事项 #

不管用哪种方案，都要记住：GC的时机是不确定的——把helper置为null后，可能要等一会儿GC才会回收它，自动取消订阅也就不是即时的。如果需要立刻取消订阅，最好给Helper加一个手动取消的兜底方法：

public void dispose() {
    if (disposable != null && !disposable.isDisposed()) {
        disposable.dispose();
        disposable = null;
    }
}

在把helper置为null前先调用helper.dispose()，这样能保证即时取消，GC时的自动处理只是额外的兜底保障。

内容的提问来源于stack exchange，提问作者tir38