Android中使用Rxjava時，內存泄漏了嗎?

kpns9444 8年前發布 | 20K 次閱讀 RxJava Android Android開發移動開發

今天有位同學問了我一個問題，話說，問我

“有遇到網絡請求一半，退出Activity造成的Theard泄露嗎？已在銷毀時調用了un了

我去查看了下rx的源碼的unsubscribe方法，定位到一個實現類，NewThreadWorker的unsubscribe方法中，源碼如下：

@Override
    public void unsubscribe() {
        isUnsubscribed = true;
        executor.shutdownNow();
        deregisterExecutor(executor);
    }

    @Override
    public boolean isUnsubscribed() {
        return isUnsubscribed;
    }

這個shutdownNow()在java的注釋中寫的很清楚

There are no guarantees beyond best-effort attempts to stop* processing actively executing tasks.

public interface ExecutorService extends Executor {

    /**
     * Initiates an orderly shutdown in which previously submitted
     * tasks are executed, but no new tasks will be accepted.
     * Invocation has no additional effect if already shut down.
     *
     * <p>This method does not wait for previously submitted tasks to
     * complete execution.  Use {@link #awaitTermination awaitTermination}
     * to do that.
     */
    void shutdown();

    /**
     * Attempts to stop all actively executing tasks, halts the
     * processing of waiting tasks, and returns a list of the tasks
     * that were awaiting execution.
     *
     * <p>This method does not wait for actively executing tasks to
     * terminate.  Use {@link #awaitTermination awaitTermination} to
     * do that.
     *
     * <p>There are no guarantees beyond best-effort attempts to stop
     * processing actively executing tasks.  For example, typical
     * implementations will cancel via {@link Thread#interrupt}, so any
     * task that fails to respond to interrupts may never terminate.
     *
     * @return list of tasks that never commenced execution
     */
    List<Runnable> shutdownNow();

它只是盡量保證停止所有tasks，因為，如果耗時操作沒有做完，finished掉activity，同時unsubscribe 掉Subscription的話，可能還有后臺線程在做一些耗時任務。那么會不會造成內存泄露呢？

我覺得還是要源碼來說說話吧

 /**
     * Unsubscribe from all of the subscriptions in the list, which stops the receipt of notifications on
     * the associated {@code Subscriber}.
     */
    @Override
    public void unsubscribe() {
        if (!unsubscribed) {
            List<Subscription> list;
            synchronized (this) {
                if (unsubscribed) {
                    return;
                }
                unsubscribed = true;
                list = subscriptions;
                subscriptions = null;
            }
            // we will only get here once
            unsubscribeFromAll(list);
        }
    }

    private static void unsubscribeFromAll(Collection<Subscription> subscriptions) {
        if (subscriptions == null) {
            return;
        }
        List<Throwable> es = null;
        for (Subscription s : subscriptions) {
            try {
                s.unsubscribe();
            } catch (Throwable e) {
                if (es == null) {
                    es = new ArrayList<Throwable>();
                }
                es.add(e);
            }
        }
        Exceptions.throwIfAny(es);
    }

實際上會做一些清除引用，暫停任務的操作。因此，一般來講在activity的ondestroy中調用unsubscribe之后，是不會造成內存泄露的。但是真的是這樣的嗎？讓我們來做做實驗吧，結果說明一切。

為了能夠更好的證明這一點，我還特意做了一個app demo去驗證。

主要代碼：

你使用Rxjava時，內存泄漏了嗎?

demo地址已經放到了github上: 內存泄露分析

啟動app，首先進入的是MainActivity,然后，我們進入SecondActivity這時候，onresume執行，我們的任務也就開始了，稍微過幾秒，我們退出SecondActivity，回到MainActivity，這之后，顯然，SecondActivity的ondestory方法會被執行，我們可以發現日志也停止了打印。

你使用Rxjava時，內存泄漏了嗎?

耗時任務正在執行

如上圖所示，停留在了5就不在執行了。

這時候，我們GC一下，在導出hprof文件，注意，為什么要手動GC一下呢？因為android虛擬機去GC也是有策略的，有GC周期的。這時候可能并沒有GC過，也就是說，SecondActivity的內存可能并沒有被釋放，但并不等于說，SecondActivity就泄露了，因為他也有可能是可以被GC的，只是還沒有來得及被GC而已。總之，在導出hprof文件之前，最好先手動GC一下。就是下圖那個車子，嗯，點一下吧，放心點。

你使用Rxjava時，內存泄漏了嗎?