Fresco源码解析 - DataSource怎样存储数据

datasource是一个独立的 package，与FB导入的guava包都在同一个工程内 - fbcore。

datasource的类关系比较简单，一张类图基本就可以描述清楚它们间的关系。

Unlike Futures, DataSource can issue a series of results, rather than just one.

最典型的用途就是渐进式加载图片时可以提供加载中的中间数据。

Datasource 提供了注册方法。

void subscribe(DataSubscriber<T> dataSubscriber, Executor executor);

通过 subscribe 方法我们可以把 DataSubscriber 注册成为 DataSource 的观察者，然后当 DataSource 的数据发生变化时，在 Executor 中通知所有的观察者 - DataSubscriber。

DataSubscriber 会响应数据的四种变化。

1. onNewResult
2. onFailure
3. onCancellation
4. onProgressUpdate

使用Executor来通知观察者是比较高明的，这样做可以让回调方法的执行线程交由 DataSubscriber 来处理，增加了灵活性。

Datasource 的状态记录使用了一个枚举类型。

private enum DataSourceStatus {
  // data source has not finished yet
  IN_PROGRESS,

  // data source has finished with success
  SUCCESS,

  // data source has finished with failure
  FAILURE,
}

这三种状态保存在一个成员变量(mDataSourceStatus)中。

@GuardedBy("this")
private DataSourceStatus mDataSourceStatus;

AbstractDataSource 构造时，会把 mDataSourceStatus 设置为 IN_PROGRESS。

protected AbstractDataSource() {
  mIsClosed = false;
  mDataSourceStatus = DataSourceStatus.IN_PROGRESS;
  mSubscribers = new ConcurrentLinkedQueue<>();
}

所有的观察者（订阅者）会被放在一个列表中 - mSubscribers。

private final ConcurrentLinkedQueue<Pair<DataSubscriber<T>, Executor>> mSubscribers;

如果当前的数据请求没有关闭并且满足mDataSourceStatus == DataSourceStatus.IN_PROGRESS时才能注册成功观察者，因为只有当数据发生变化的时候，观察者才有存在的意义。

  @Override
public void subscribe(final DataSubscriber<T> dataSubscriber, final Executor executor) {
  Preconditions.checkNotNull(dataSubscriber);
  Preconditions.checkNotNull(executor);
  boolean shouldNotify;

  synchronized(this) {
    if (mIsClosed) {
      return;
    }

    if (mDataSourceStatus == DataSourceStatus.IN_PROGRESS) {
      mSubscribers.add(Pair.create(dataSubscriber, executor));
    }

    shouldNotify = hasResult() || isFinished() || wasCancelled();
  }

  if (shouldNotify) {
    notifyDataSubscriber(dataSubscriber, executor, hasFailed(), wasCancelled());
  }
}

如果 DataSource 有了新的数据或者请求已经结束掉或被取消掉，会通知观察者。

private void notifyDataSubscribers() {
  final boolean isFailure = hasFailed();
  final boolean isCancellation = wasCancelled();
  for (Pair<DataSubscriber<T>, Executor> pair : mSubscribers) {
    notifyDataSubscriber(pair.first, pair.second, isFailure, isCancellation);
  }
}

private void notifyDataSubscriber(
    final DataSubscriber<T> dataSubscriber,
    final Executor executor,
    final boolean isFailure,
    final boolean isCancellation) {
  executor.execute(
      new Runnable() {
        @Override
        public void run() {
          if (isFailure) {
            dataSubscriber.onFailure(AbstractDataSource.this);
          } else if (isCancellation) {
            dataSubscriber.onCancellation(AbstractDataSource.this);
          } else {
            dataSubscriber.onNewResult(AbstractDataSource.this);
          }
        }
      });
}

使用 DataSubscriber 注册成为了观察者后，回调方法都会带回一个 DataSource 的实例，如果请求已经结束后者失败了，拿到数据后一定要把 DataSource 给 close 掉，否则很容易造成 OOM。

BaseDataSubscriber 就是为了防止OOM，它本身的设计也很巧妙。

在毁掉方法 onNewResult 和 onFailure 中加了一个 try - catch， 在 try 的 block 中调用子类必须重载的 onNewResultImpl 方法，然后在 finally 的 block 中 close DataSource。

DataSourceSubscriber.java

public abstract class BaseDataSubscriber<T> implements DataSubscriber<T> {

  @Override
  public void onNewResult(DataSource<T> dataSource) {
    try {
      onNewResultImpl(dataSource);
    } finally {
      if (dataSource.isFinished()) {
        dataSource.close();
      }
    }
  }

  @Override
  public void onFailure(DataSource<T> dataSource) {
    try {
      onFailureImpl(dataSource);
    } finally {
      dataSource.close();
    }
  }

  @Override
  public void onCancellation(DataSource<T> dataSource) {
  }

  @Override
  public void onProgressUpdate(DataSource<T> dataSource) {
  }

  protected abstract void onNewResultImpl(DataSource<T> dataSource);

  protected abstract void onFailureImpl(DataSource<T> dataSource);
}

A class that can supply objects of a single type. Semantically, this could be a factory, generator, builder, closure, or something else entirely. No guarantees are implied by this interface.

Preconditions

• checkArgument
• checkState
• checkNotNull
• checkElementIndex
• checkPositionIndex
• checkPositionIndexes

如果 check 结果为 false， 则抛出异常。Fresco 的错误处理基本上是用异常做的。