@Override
  public void produceResults(final Consumer<CloseableReference<CloseableImage>> consumer, final ProducerContext producerContext) {
    final ImageRequest imageRequest = producerContext.getImageRequest();
    ProgressiveDecoder progressiveDecoder;
    if (!UriUtil.isNetworkUri(imageRequest.getSourceUri())) {
      progressiveDecoder = new LocalImagesProgressiveDecoder(consumer, producerContext, mDecodeCancellationEnabled);
    } else {
      ProgressiveJpegParser jpegParser = new ProgressiveJpegParser(mByteArrayPool);
      progressiveDecoder = new NetworkImagesProgressiveDecoder(consumer, producerContext, jpegParser, mProgressiveJpegConfig, mDecodeCancellationEnabled);
    }
    mInputProducer.produceResults(progressiveDecoder, producerContext);
  }

/** Performs the decode synchronously. */
private void doDecode(EncodedImage encodedImage, @Status int status) {
  if (isFinished() || !EncodedImage.isValid(encodedImage)) {
    return;
  }
  final String imageFormatStr;
  ImageFormat imageFormat = encodedImage.getImageFormat();
  if (imageFormat != null) {
    imageFormatStr = imageFormat.getName();
  } else {
    imageFormatStr = "unknown";
  }
  final String encodedImageSize;
  final String sampleSize;
  final boolean isLast = isLast(status);
  final boolean isLastAndComplete = isLast && !statusHasFlag(status, IS_PARTIAL_RESULT);
  final boolean isPlaceholder = statusHasFlag(status, IS_PLACEHOLDER);
  if (encodedImage != null) {
    encodedImageSize = encodedImage.getWidth() + "x" + encodedImage.getHeight();
    sampleSize = String.valueOf(encodedImage.getSampleSize());
  } else {
    // We should never be here
    encodedImageSize = "unknown";
    sampleSize = "unknown";
  }
  final String requestedSizeStr;
  final ResizeOptions resizeOptions = mProducerContext.getImageRequest().getResizeOptions();
  if (resizeOptions != null) {
    requestedSizeStr = resizeOptions.width + "x" + resizeOptions.height;
  } else {
    requestedSizeStr = "unknown";
  }
  try {
    long queueTime = mJobScheduler.getQueuedTime();
    long decodeDuration = -1;
    String imageUrl = encodedImage.getEncodedCacheKey().getUriString();
    int length = isLastAndComplete || isPlaceholder ? encodedImage.getSize() : getIntermediateImageEndOffset(encodedImage);
    QualityInfo quality = isLastAndComplete || isPlaceholder ? ImmutableQualityInfo.FULL_QUALITY : getQualityInfo();

    mProducerListener.onProducerStart(mProducerContext.getId(), PRODUCER_NAME);
    CloseableImage image = null;
    try {
      long nowTime = System.currentTimeMillis();
      image = mImageDecoder.decode(encodedImage, length, quality, mImageDecodeOptions);
      decodeDuration = System.currentTimeMillis() - nowTime;
    } catch (Exception e) {
      Map<String, String> extraMap = getExtraMap(image, imageUrl, queueTime, decodeDuration, quality, isLast, imageFormatStr, encodedImageSize, requestedSizeStr, sampleSize);
      mProducerListener.onProducerFinishWithFailure(mProducerContext.getId(), PRODUCER_NAME, e, extraMap);
      handleError(e);
      return;
    }
    Map<String, String> extraMap = getExtraMap(image, imageUrl, queueTime, decodeDuration, quality, isLast, imageFormatStr, encodedImageSize, requestedSizeStr, sampleSize);
    mProducerListener.onProducerFinishWithSuccess(mProducerContext.getId(), PRODUCER_NAME, extraMap);
    handleResult(image, status);
  } finally {
    EncodedImage.closeSafely(encodedImage);
  }
}

  long nowTime = System.currentTimeMillis();
  image = mImageDecoder.decode(encodedImage, length, quality, mImageDecodeOptions);
  decodeDuration = System.currentTimeMillis() - nowTime;

  private final ImageDecoder mDefaultDecoder = new ImageDecoder() {
    @Override
    public CloseableImage decode(EncodedImage encodedImage, int length, QualityInfo qualityInfo, ImageDecodeOptions options) {
      ImageFormat imageFormat = encodedImage.getImageFormat();
      if (imageFormat == DefaultImageFormats.JPEG) {
        return decodeJpeg(encodedImage, length, qualityInfo, options);
      } else if (imageFormat == DefaultImageFormats.GIF) {
        return decodeGif(encodedImage, length, qualityInfo, options);
      } else if (imageFormat == DefaultImageFormats.WEBP_ANIMATED) {
        return decodeAnimatedWebp(encodedImage, length, qualityInfo, options);
      } else if (imageFormat == ImageFormat.UNKNOWN) {
        throw new IllegalArgumentException("unknown image format");
      }
      return decodeStaticImage(encodedImage, options);
    }
  };

  public static final ImageFormat JPEG = new ImageFormat("JPEG", "jpeg");
  public static final ImageFormat PNG = new ImageFormat("PNG", "png");
  public static final ImageFormat GIF = new ImageFormat("GIF", "gif");
  public static final ImageFormat BMP = new ImageFormat("BMP", "bmp");
  public static final ImageFormat WEBP_SIMPLE = new ImageFormat("WEBP_SIMPLE", "webp");
  public static final ImageFormat WEBP_LOSSLESS = new ImageFormat("WEBP_LOSSLESS", "webp");
  public static final ImageFormat WEBP_EXTENDED = new ImageFormat("WEBP_EXTENDED", "webp");
  public static final ImageFormat WEBP_EXTENDED_WITH_ALPHA = new ImageFormat("WEBP_EXTENDED_WITH_ALPHA", "webp");
  public static final ImageFormat WEBP_ANIMATED = new ImageFormat("WEBP_ANIMATED", "webp");

  private static AnimatedImageDecoder loadIfPresent(final String className) {
    try {
      Class<?> clazz = Class.forName(className);
      return (AnimatedImageDecoder) clazz.newInstance();
    } catch (Throwable e) {
      return null;
    }
  }

  static {
    sGifAnimatedImageDecoder = loadIfPresent("com.facebook.animated.gif.GifImage");
    sWebpAnimatedImageDecoder = loadIfPresent("com.facebook.animated.webp.WebPImage");
  }

public interface PlatformDecoder {
  /**
   * Creates a bitmap from encoded bytes. Supports JPEG but callers should use {@link
   * #decodeJPEGFromEncodedImage} for partial JPEGs.
   *
   * @param encodedImage the reference to the encoded image with the reference to the encoded bytes
   * @param bitmapConfig the {@link android.graphics.Bitmap.Config} used to create the decoded
   * Bitmap
   * @return the bitmap
   * @throws TooManyBitmapsException if the pool is full
   * @throws java.lang.OutOfMemoryError if the Bitmap cannot be allocated
   */
  CloseableReference<Bitmap> decodeFromEncodedImage(final EncodedImage encodedImage, Bitmap.Config bitmapConfig);

  /**
   * Creates a bitmap from encoded JPEG bytes. Supports a partial JPEG image.
   *
   * @param encodedImage the reference to the encoded image with the reference to the encoded bytes
   * @param bitmapConfig the {@link android.graphics.Bitmap.Config} used to create the decoded
   * Bitmap
   * @param length the number of encoded bytes in the buffer
   * @return the bitmap
   * @throws TooManyBitmapsException if the pool is full
   * @throws java.lang.OutOfMemoryError if the Bitmap cannot be allocated
   */
  CloseableReference<Bitmap> decodeJPEGFromEncodedImage(EncodedImage encodedImage, Bitmap.Config bitmapConfig, int length);
}


getBitmapFactoryOptions 获取BitmapFactory.Options
decodeByteArrayAsPurgeable 获取bitmap
pinBitmap 真正的decode

  private void handleFinalResult(PooledByteBufferOutputStream pooledOutputStream, FetchState fetchState) {
    Map<String, String> extraMap = getExtraMap(fetchState, pooledOutputStream.size());
    ProducerListener listener = fetchState.getListener();
    listener.onProducerFinishWithSuccess(fetchState.getId(), PRODUCER_NAME, extraMap);
    listener.onUltimateProducerReached(fetchState.getId(), PRODUCER_NAME, true);
    notifyConsumer(pooledOutputStream, Consumer.IS_LAST | fetchState.getOnNewResultStatusFlags(), fetchState.getResponseBytesRange(), fetchState.getConsumer());
  }

@Override
public void onCreate() {
    super.onCreate();
    FLog.setMinimumLoggingLevel(FLog.VERBOSE);
    Set<RequestListener> listeners = new HashSet<>(1);
    listeners.add(new RequestLoggingListener());
    ImagePipelineConfig config = ImagePipelineConfig.newBuilder(this)
        .setRequestListeners(listeners)
        .setNetworkFetcher(new OkHttpNetworkFetcher(OKHttpFactory.getInstance().getOkHttpClient()))
        .build();
    DraweeConfig draweeConfig = DraweeConfig.newBuilder().setDrawDebugOverlay(DebugOverlayHelper.isDebugOverlayEnabled(this)).build();
    Fresco.initialize(this, config, draweeConfig);
    Fresco.getImagePipeline().clearDiskCaches();
}

  @Override
  public synchronized void onProducerFinishWithSuccess(String requestId, String producerName, @Nullable Map<String, String> extraMap) {
    if (FLog.isLoggable(FLog.VERBOSE)) {
      Pair<String, String> mapKey = Pair.create(requestId, producerName);
      Long startTime = mProducerStartTimeMap.remove(mapKey);
      long currentTime = getTime();
      long producerDuration = -1;
      FLog.v(TAG, "time %d: onProducerFinishWithSuccess: " + "{requestId: %s, producer: %s, elapsedTime: %d ms, extraMap: %s}", currentTime, requestId, producerName, producerDuration = getElapsedTime(startTime, currentTime), extraMap);
      if (sOnProducer != null) {
        sOnProducer.onProducer(producerDuration, extraMap, producerName);
      }
    }
  }

 long nowTime = System.currentTimeMillis();
 image = mImageDecoder.decode(encodedImage, length, quality, mImageDecodeOptions);
 decodeDuration = System.currentTimeMillis() - nowTime;

  public static final String QUEUE_TIME = "resp_time"; //修改为响应时间
  public static final String FETCH_TIME = "fetch_time";
  public static final String TOTAL_TIME = "total_time";
  public static final String IMAGE_SIZE = "image_size";
  public static final String IMAGE_URL = "image_url"; //新增

./run -chart -include=kryo,fst-serialization,java-built-in,protobuf,hessian,json/google-gson/databind,
xml/xstream+c,bson/mongodb,bson/jackson/databind,json/fastjson/databind,json/jackson/databind,thrift,avro-generic data/media.1.cks

[Protobuf](https://code.google.com/p/protobuf/)、[Thrift](https://thrift.apache.org/)、 [AvroGeneric](https://avro.apache.org/docs/current/)、[Hessian](http://hessian.caucho.com/)

binary > textual
language-specific > language-unspecific

private static Kryo myKryo = new Kryo();
static {
    myKryo.register(MusicInfo.class, new CompatibleFieldSerializer<MusicInfo>(myKryo, Media.class), 50);
}
public static void saveObjectByKryo(Object o, String fileName) {
    Output output = null;
    try {
        output = new Output(new FileOutputStream(fileName), 8 * 1024);
        myKryo.writeObject(output, o);
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        if (output != null) {
         output.close();
        }
    }
}

public static Object readObjectByKryo(String filename, Class<?> clazz) {
    Input input = null;
    try {
        input = new Input(new FileInputStream(new File(filename)));
        return myKryo.readObject(input, clazz);
    } catch (Throwable t) {
        t.printStackTrace();
    } finally {
        if (input != null) {
            input.close();
        }
    }
    return null;
}

public static boolean saveObjectByJava(Object o, String filename) {
    FSTObjectOutput oos = null;
    ObjectOutputStream oos = null;
    try {
        oos = new FSTObjectOutput(new FileOutputStream(filename));
        oos.writeObject(o);
        oos.flush();
        return true;
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        if (oos != null) {
        try {
            oos.close();
            } catch (IOException e) {
            e.printStackTrace();
            }
        }
    }
    return false;
}
public static Object readObjectByJava(String filename) {
    FSTObjectInput ois = null;
    ObjectInputStream ois = null;
    try {
        ois = new ObjectInputStream(new FileInputStream(filename));
        return ois.readObject();
    } catch (Throwable t) {
        t.printStackTrace();
    } finally {
        if (ois != null) {
            try {
                ois.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    return null;
}

cd ~/octopress
git branch # *source

git push origin source #即将本地内容push到远端git repo 的source分支上。

cd ~/octopress/_deploy
git branch # *master

$ git --version

$ ruby --version #shold be 1.9.3#p125 or other version can be set up an octopress

git clone -b source git@github.com:username/username.github.com.git octopress 

$ cd octopress #进入到octopress目录下，看看_deploy是否存在，存在的话且不为空，先清空
$ git clone git@github.com:username/username.github.com.git _deploy  #clone master分支

$ gem install bundler
$ rbenv rehash
$ bundle install

rake setup_github_pages

Enter the read/write url for your repository

git remote -v

octopress git://github.com/imathis/octopress.git (fetch)
octopress git://github.com/imathis/octopress.git (push)
origin    https://github.com/username/username.github.io (fetch)  #关联blog 的远程 repo
origin    https://github.com/username/username.github.io (push)

rake new_post['new post on new computer']

git add .
git commit -m 'create a new post in new compter'
git push origin source #push source内容到repo上

rake deploy 发布blog

cd octopress
git pull origin source  # 同步source分支
cd octopress/_deploy
git pull origin master  # 同步master分支， 因为之前rake dedploy会修改master的内容

$ git --version

$ ruby --version #此时应该已是1.9.3p125 (2012-02-16 revision 34643)，或者其他你成功安装了octopress的ruby版本

$ cd ~
$ mkdir anotherBlog #作为第二个octopress所在目录
$ cd anotherBlog
$ git clone git://github.com/imathis/octopress.git octopress 

$ruby --version #如果跟第一个octopress所在目录下version版本一致即可，不一样的话，参考第一篇中介绍rbenv 环境变量的设置

$ gem install bundler
$ rbenv rehash
$ bundle install

$ rake install #默认主题

$ rake setup_github_pages

$ git remote -v #关联的远程repo信息

octopress    git://github.com/imathis/octopress.git (fetch)
octopress git://github.com/imathis/octopress.git (push)
origin    https://github.com/anotherUsername/anotherUsername.github.io (fetch)
origin    https://github.com/anotherUsername/anotherUsername.github.io (push)

$ rake generate

$ rake preview #http://localhost:4000# ，preview一下另一个blog

$ git --version

$ ruby --version

$ ruby -e "$(curl -fsSL https://raw.github.com/Homebrew/homebrew/go/install)"

$ brew update 
$ brew install rbenv
$ brew install ruby-build

$ rbenv install 1.9.3-p125
$ rbenv local 1.9.3-p125 #Sets a local application-specific Ruby version
$ rbenv rehash
$ ruby --version #ruby 1.9.3p125 (2012-02-16 revision 34643) [x86_64-darwin13.1.0]

cd ~/.bash_profile

$ echo 'export PATH="$HOME/.rbenv/bin:$PATH"' >> ~/.bash_profile

$ echo 'eval "$(rbenv init -)"' >> ~/.bash_profile

$ source ~/.bash_profile

$ ruby --version #此时应该已是1.9.3p125 (2012-02-16 revision 34643)

$ git clone git://github.com/imathis/octopress.git octopress

$ cd octopress
$ gem install bundler
$ rbenv rehash
$ bundle install

$ rake install

$ rake setup_github_pages

$ rake generate 

$ git add .
$ git commit -m 'create first blog'
$ git push origin source

$ rake deploy

url:                # For rewriting urls for RSS, etc
title:              # Used in the header and title tags
subtitle:           # A description used in the header
author:             # Your name, for RSS, Copyright, Metadata
simple_search:      # Search engine for simple site search
description:        # A default meta description for your site
date_format:        # Format dates using Ruby's date strftime syntax
subscribe_rss:      # Url for your blog's feed, defauts to /atom.xml
subscribe_email:    # Url to subscribe by email (service required)
category_feeds:     # Enable per category RSS feeds (defaults to false in 2.1)
email:              # Email address for the RSS feed if you want it.

$ rake generate

$ git add .
$ git commit -m "settings" 
$ git push origin source

$ rake deploy

$ rake new_post['hello world']

$ rake preview #localhost:4000

$ rake generate

$ git add .
$ git commit -m "comment" 
$ git push origin source

$ rake deploy