okhttp3.internal.Util.threadFactory()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(9.6k)|赞(0)|评价(0)|浏览(262)

本文整理了Java中okhttp3.internal.Util.threadFactory()方法的一些代码示例，展示了Util.threadFactory()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Util.threadFactory()方法的具体详情如下：
包路径：okhttp3.internal.Util
类名称：Util
方法名：threadFactory

Util.threadFactory介绍

暂无

代码示例

代码示例来源：origin: square/okhttp

public synchronized ExecutorService executorService() {
 if (executorService == null) {
  executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
    new SynchronousQueue<>(), Util.threadFactory("OkHttp Dispatcher", false));
 }
 return executorService;
}

代码示例来源：origin: square/okhttp

/**
 * Create a cache which will reside in {@code directory}. This cache is lazily initialized on
 * first access and will be created if it does not exist.
 *
 * @param directory a writable directory
 * @param valueCount the number of values per cache entry. Must be positive.
 * @param maxSize the maximum number of bytes this cache should use to store
 */
public static DiskLruCache create(FileSystem fileSystem, File directory, int appVersion,
  int valueCount, long maxSize) {
 if (maxSize <= 0) {
  throw new IllegalArgumentException("maxSize <= 0");
 }
 if (valueCount <= 0) {
  throw new IllegalArgumentException("valueCount <= 0");
 }
 // Use a single background thread to evict entries.
 Executor executor = new ThreadPoolExecutor(0, 1, 60L, TimeUnit.SECONDS,
   new LinkedBlockingQueue<>(), Util.threadFactory("OkHttp DiskLruCache", true));
 return new DiskLruCache(fileSystem, directory, appVersion, valueCount, maxSize, executor);
}

代码示例来源：origin: com.squareup.okhttp3/okhttp

public synchronized ExecutorService executorService() {
 if (executorService == null) {
  executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
    new SynchronousQueue<>(), Util.threadFactory("OkHttp Dispatcher", false));
 }
 return executorService;
}

代码示例来源：origin: JessYanCoding/MVPArms

/**
 * 返回一个全局公用的线程池,适用于大多数异步需求。
 * 避免多个线程池创建带来的资源消耗。
 *
 * @return {@link Executor}
 */
@Singleton
@Provides
ExecutorService provideExecutorService() {
  return mExecutorService == null ? new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
      new SynchronousQueue<Runnable>(), Util.threadFactory("Arms Executor", false)) : mExecutorService;
}

代码示例来源：origin: square/okhttp

started = true;
executor = Executors.newCachedThreadPool(Util.threadFactory("MockWebServer", false));
this.inetSocketAddress = inetSocketAddress;
serverSocket = serverSocketFactory.createServerSocket();

代码示例来源：origin: square/okhttp

public void initReaderAndWriter(String name, Streams streams) throws IOException {
 synchronized (this) {
  this.streams = streams;
  this.writer = new WebSocketWriter(streams.client, streams.sink, random);
  this.executor = new ScheduledThreadPoolExecutor(1, Util.threadFactory(name, false));
  if (pingIntervalMillis != 0) {
   executor.scheduleAtFixedRate(
     new PingRunnable(), pingIntervalMillis, pingIntervalMillis, MILLISECONDS);
  }
  if (!messageAndCloseQueue.isEmpty()) {
   runWriter(); // Send messages that were enqueued before we were connected.
  }
 }
 reader = new WebSocketReader(streams.client, streams.source, this);
}

代码示例来源：origin: com.squareup.okhttp3/okhttp

/**
 * Create a cache which will reside in {@code directory}. This cache is lazily initialized on
 * first access and will be created if it does not exist.
 *
 * @param directory a writable directory
 * @param valueCount the number of values per cache entry. Must be positive.
 * @param maxSize the maximum number of bytes this cache should use to store
 */
public static DiskLruCache create(FileSystem fileSystem, File directory, int appVersion,
  int valueCount, long maxSize) {
 if (maxSize <= 0) {
  throw new IllegalArgumentException("maxSize <= 0");
 }
 if (valueCount <= 0) {
  throw new IllegalArgumentException("valueCount <= 0");
 }
 // Use a single background thread to evict entries.
 Executor executor = new ThreadPoolExecutor(0, 1, 60L, TimeUnit.SECONDS,
   new LinkedBlockingQueue<>(), Util.threadFactory("OkHttp DiskLruCache", true));
 return new DiskLruCache(fileSystem, directory, appVersion, valueCount, maxSize, executor);
}

代码示例来源：origin: square/okhttp

Util.threadFactory(Util.format("OkHttp %s Writer", connectionName), false));
if (builder.pingIntervalMillis != 0) {
 writerExecutor.scheduleAtFixedRate(new PingRunnable(false, 0, 0),
  Util.threadFactory(Util.format("OkHttp %s Push Observer", connectionName), true));
peerSettings.set(Settings.INITIAL_WINDOW_SIZE, DEFAULT_INITIAL_WINDOW_SIZE);
peerSettings.set(Settings.MAX_FRAME_SIZE, Http2.INITIAL_MAX_FRAME_SIZE);

代码示例来源：origin: com.squareup.okhttp3/okhttp

public void initReaderAndWriter(String name, Streams streams) throws IOException {
 synchronized (this) {
  this.streams = streams;
  this.writer = new WebSocketWriter(streams.client, streams.sink, random);
  this.executor = new ScheduledThreadPoolExecutor(1, Util.threadFactory(name, false));
  if (pingIntervalMillis != 0) {
   executor.scheduleAtFixedRate(
     new PingRunnable(), pingIntervalMillis, pingIntervalMillis, MILLISECONDS);
  }
  if (!messageAndCloseQueue.isEmpty()) {
   runWriter(); // Send messages that were enqueued before we were connected.
  }
 }
 reader = new WebSocketReader(streams.client, streams.source, this);
}

代码示例来源：origin: com.squareup.okhttp3/okhttp

Util.threadFactory(Util.format("OkHttp %s Writer", connectionName), false));
if (builder.pingIntervalMillis != 0) {
 writerExecutor.scheduleAtFixedRate(new PingRunnable(false, 0, 0),
  Util.threadFactory(Util.format("OkHttp %s Push Observer", connectionName), true));
peerSettings.set(Settings.INITIAL_WINDOW_SIZE, DEFAULT_INITIAL_WINDOW_SIZE);
peerSettings.set(Settings.MAX_FRAME_SIZE, Http2.INITIAL_MAX_FRAME_SIZE);

代码示例来源：origin: duzechao/OKHttpUtils

public synchronized ExecutorService executorService() {
 if (executorService == null) {
  executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
    new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false));
 }
 return executorService;
}

代码示例来源：origin: huxq17/SwipeCardsView

public synchronized ExecutorService getExecutorService() {
 if (executorService == null) {
  executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
    new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false));
 }
 return executorService;
}

代码示例来源：origin: com.github.ljun20160606/okhttp

public synchronized ExecutorService executorService() {
 if (executorService == null) {
  executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
    new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false));
 }
 return executorService;
}

代码示例来源：origin: huxq17/tractor

public synchronized ExecutorService getExecutorService() {
 if (executorService == null) {
  executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
    new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false));
 }
 return executorService;
}

代码示例来源：origin: apache/servicemix-bundles

public synchronized ExecutorService executorService() {
 if (executorService == null) {
  executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
    new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false));
 }
 return executorService;
}

代码示例来源：origin: JessYanCoding/MVPArt

/**
 * 返回一个全局公用的线程池,适用于大多数异步需求。
 * 避免多个线程池创建带来的资源消耗。
 *
 * @return {@link Executor}
 */
@Singleton
@Provides
ExecutorService provideExecutorService() {
  return mExecutorService == null ? new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
      new SynchronousQueue<Runnable>(), Util.threadFactory("Art Executor", false)) : mExecutorService;
}

代码示例来源：origin: com.squareup.okhttp3/okhttp-ws

static RealWebSocket create(StreamAllocation streamAllocation, Response response,
  Random random, WebSocketListener listener) {
 String url = response.request().url().toString();
 ThreadPoolExecutor replyExecutor =
   new ThreadPoolExecutor(1, 1, 1, SECONDS, new LinkedBlockingDeque<Runnable>(),
     Util.threadFactory(Util.format("OkHttp %s WebSocket", url), true));
 replyExecutor.allowCoreThreadTimeOut(true);
 return new StreamWebSocket(streamAllocation, random, replyExecutor, listener, url);
}

代码示例来源：origin: io.zipkin.reporter2/zipkin-sender-okhttp3

static Dispatcher newDispatcher(int maxRequests) {
 // bound the executor so that we get consistent performance
 ThreadPoolExecutor dispatchExecutor =
   new ThreadPoolExecutor(0, maxRequests, 60, TimeUnit.SECONDS,
     // Using a synchronous queue means messages will send immediately until we hit max
     // in-flight requests. Once max requests are hit, send will block the caller, which is
     // the AsyncReporter flush thread. This is ok, as the AsyncReporter has a buffer of
     // unsent spans for this purpose.
     new SynchronousQueue<>(),
     Util.threadFactory("OkHttpSender Dispatcher", false));
 Dispatcher dispatcher = new Dispatcher(dispatchExecutor);
 dispatcher.setMaxRequests(maxRequests);
 dispatcher.setMaxRequestsPerHost(maxRequests);
 return dispatcher;
}

代码示例来源：origin: apache/servicemix-bundles

public void initReaderAndWriter(String name, Streams streams) throws IOException {
 synchronized (this) {
  this.streams = streams;
  this.writer = new WebSocketWriter(streams.client, streams.sink, random);
  this.executor = new ScheduledThreadPoolExecutor(1, Util.threadFactory(name, false));
  if (pingIntervalMillis != 0) {
   executor.scheduleAtFixedRate(
     new PingRunnable(), pingIntervalMillis, pingIntervalMillis, MILLISECONDS);
  }
  if (!messageAndCloseQueue.isEmpty()) {
   runWriter(); // Send messages that were enqueued before we were connected.
  }
 }
 reader = new WebSocketReader(streams.client, streams.source, this);
}

代码示例来源：origin: com.github.ljun20160606/okhttp

public void initReaderAndWriter(
  String name, long pingIntervalMillis, Streams streams) throws IOException {
 synchronized (this) {
  this.streams = streams;
  this.writer = new WebSocketWriter(streams.client, streams.sink, random);
  this.executor = new ScheduledThreadPoolExecutor(1, Util.threadFactory(name, false));
  if (pingIntervalMillis != 0) {
   executor.scheduleAtFixedRate(
     new PingRunnable(), pingIntervalMillis, pingIntervalMillis, MILLISECONDS);
  }
  if (!messageAndCloseQueue.isEmpty()) {
   runWriter(); // Send messages that were enqueued before we were connected.
  }
 }
 reader = new WebSocketReader(streams.client, streams.source, this);
}

内容来源于网络，如有侵权，请联系作者删除！

Util

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com