java - 不同任务的ThreadPoolExecutor

Question

下面是默认的 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();
    }
  }

Answer 1

类 PicassoExecutorService 是执行程序服务的实现，它调整连接类型的线程计数。 IE。对于 2G，它选择 1 个线程，因为 2G 速度很慢，并且设置 4 个并发线程会耗尽您的连接。

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

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

如果您在尝试从互联网获取作业之前无法确定作业是否已缓存，我将使用相当复杂的策略来更新答案。

更新

策略。

首先，您需要了解所有设备上的磁盘读取超时。您需要 95% 的超时值，例如小于最大值的值。所以如果你有1ms、2ms、1ms、50ms、20ms、3ms，你就不要选择20ms或50ms。设磁盘读取时间为 3ms。您的平均(或更好的中值)连接超时应该大得多 - 例如 100-500 毫秒。

因此，我们的想法是首先将作业提交到一个由 10-20 个线程组成的线程池，并且超时时间很短。因此它将过滤掉所有慢速作业。

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

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