1

波纹管是默认的 PicassoExecutorService.java ，它只是从网络（以及从 http 缓存，如果之前加载）请求位图。比如说，如果有 100 个任务，95 个加载到缓存中，5 个来自网络，如果队列的前 5 个中的 5 个，则在加载第 5 个图片时将永远不会显示 95 个图像。所以，我想更改 PicassoExecutorService.java，我想知道是否可以在 ExecutorService 中创建一个新线程来执行磁盘缓存获取工作？我应该创建一个新队列吗？我对java线程编码没有太多经验，所以我需要你的帮助，谢谢。

class PicassoExecutorService extends ThreadPoolExecutor {
  private static final int DEFAULT_THREAD_COUNT = 3;

  PicassoExecutorService() {
    super(DEFAULT_THREAD_COUNT, DEFAULT_THREAD_COUNT, 0, TimeUnit.MILLISECONDS,
        new LinkedBlockingQueue<Runnable>(), new Utils.PicassoThreadFactory());
  }

  void adjustThreadCount(NetworkInfo info) {
    if (info == null || !info.isConnectedOrConnecting()) {
      setThreadCount(DEFAULT_THREAD_COUNT);
      return;
    }
    switch (info.getType()) {
      case ConnectivityManager.TYPE_WIFI:
      case ConnectivityManager.TYPE_WIMAX:
      case ConnectivityManager.TYPE_ETHERNET:
        setThreadCount(4);
        break;
      case ConnectivityManager.TYPE_MOBILE:
        switch (info.getSubtype()) {
          case TelephonyManager.NETWORK_TYPE_LTE:  // 4G
          case TelephonyManager.NETWORK_TYPE_HSPAP:
          case TelephonyManager.NETWORK_TYPE_EHRPD:
            setThreadCount(3);
            break;
          case TelephonyManager.NETWORK_TYPE_UMTS: // 3G
          case TelephonyManager.NETWORK_TYPE_CDMA:
          case TelephonyManager.NETWORK_TYPE_EVDO_0:
          case TelephonyManager.NETWORK_TYPE_EVDO_A:
          case TelephonyManager.NETWORK_TYPE_EVDO_B:
            setThreadCount(2);
            break;
          case TelephonyManager.NETWORK_TYPE_GPRS: // 2G
          case TelephonyManager.NETWORK_TYPE_EDGE:
            setThreadCount(1);
            break;
          default:
            setThreadCount(DEFAULT_THREAD_COUNT);
        }
        break;
      default:
        setThreadCount(DEFAULT_THREAD_COUNT);
    }
  }

  private void setThreadCount(int threadCount) {
    setCorePoolSize(threadCount);
    setMaximumPoolSize(threadCount);
  }
}



  static class PicassoThreadFactory implements ThreadFactory {
    @SuppressWarnings("NullableProblems")
    public Thread newThread(Runnable r) {
      return new PicassoThread(r);
    }
  }

  private static class PicassoThread extends Thread {
    public PicassoThread(Runnable r) {
      super(r);
    }

    @Override public void run() {
      Process.setThreadPriority(THREAD_PRIORITY_BACKGROUND);
      super.run();
    }
  }
4

1 回答 1

2

该类PicassoExecutorService是执行器服务的实现，它调整连接类型的线程数。即对于 2G，它选择 1 个线程，因为 2G 很慢，同时设置 4 个线程会耗尽您的连接。

您面临的问题是因为一些未缓存的作业领先于缓存的请求。

现在，如果您能够确定作业是否被缓存，您只需为磁盘作业创建一个单独的服务或线程。您向我们展示的线程池是一个连接线程，它根据连接类型限制资源。最好不要混淆关注点并为磁盘作业创建单独的线程池。

如果在尝试从 Internet 获取作业之前不能说作业是否已缓存，我将使用非常复杂的策略更新答案。

更新

策略。

首先，您需要了解所有设备上的磁盘读取超时。您需要第 95 个百分位的超时值，例如小于最大值的值。所以如果你有 1ms、2ms、1ms、50ms、20ms、3ms，你不要选择 20ms 或 50ms。让磁盘读取时间为 3 毫秒。您的平均（或更好的中值）连接超时应该更大——比如 100-500 毫秒。

所以这个想法是首先将您的作业提交到一个包含 10-20 个线程的线程池，并带有这个小超时。因此它将过滤掉所有缓慢的工作。

下一步是终止慢速作业。这取决于您的连接是否可中断。如果不是，这是一个不同的问题。

在此之后，您只需将慢速作业重新提交到连接线程池。就是这样。

于 2013-10-28T08:36:19.703 回答