org.jclouds.concurrent.config.WithSubmissionTrace.wrap()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(8.0k)|赞(0)|评价(0)|浏览(123)

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

WithSubmissionTrace.wrap介绍

暂无

代码示例

代码示例来源：origin: jclouds/legacy-jclouds

  1. public ExecutorServiceModule(@Named(PROPERTY_USER_THREADS) ListeningExecutorService userExecutor,
  2.    @Named(PROPERTY_IO_WORKER_THREADS) ListeningExecutorService ioExecutor) {
  3.  this.userExecutorFromConstructor = WithSubmissionTrace.wrap(userExecutor);
  4.  this.ioExecutorFromConstructor = WithSubmissionTrace.wrap(ioExecutor);
  5. }

代码示例来源：origin: io.cloudsoft.jclouds/jclouds-core

  1. public ExecutorServiceModule(@Named(PROPERTY_USER_THREADS) ListeningExecutorService userExecutor,
  2.    @Named(PROPERTY_IO_WORKER_THREADS) ListeningExecutorService ioExecutor) {
  3.  this.userExecutorFromConstructor = WithSubmissionTrace.wrap(userExecutor);
  4.  this.ioExecutorFromConstructor = WithSubmissionTrace.wrap(ioExecutor);
  5. }

代码示例来源：origin: org.jclouds/jclouds-core

  1. public ExecutorServiceModule(@Named(PROPERTY_USER_THREADS) ListeningExecutorService userExecutor,
  2.    @Named(PROPERTY_IO_WORKER_THREADS) ListeningExecutorService ioExecutor) {
  3.  this.userExecutorFromConstructor = WithSubmissionTrace.wrap(userExecutor);
  4.  this.ioExecutorFromConstructor = WithSubmissionTrace.wrap(ioExecutor);
  5. }

代码示例来源：origin: org.jclouds/jclouds-core

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_USER_THREADS)
  4. ListeningExecutorService provideListeningUserExecutorService(@Named(PROPERTY_USER_THREADS) int count, Closer closer) { // NO_UCD
  5.  if (userExecutorFromConstructor != null)
  6.    return userExecutorFromConstructor;
  7.  return shutdownOnClose(WithSubmissionTrace.wrap(newThreadPoolNamed("user thread %d", count)), closer);
  8. }

代码示例来源：origin: jclouds/legacy-jclouds

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_SCHEDULER_THREADS)
  4. ListeningScheduledExecutorService provideListeningScheduledExecutorService(
  5.    @Named(PROPERTY_SCHEDULER_THREADS) int count, Closer closer) {
  6.  return shutdownOnClose(WithSubmissionTrace.wrap(newScheduledThreadPoolNamed("scheduler thread %d", count)),
  7.     closer);
  8. }

代码示例来源：origin: jclouds/legacy-jclouds

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_USER_THREADS)
  4. ListeningExecutorService provideListeningUserExecutorService(@Named(PROPERTY_USER_THREADS) int count, Closer closer) { // NO_UCD
  5.  if (userExecutorFromConstructor != null)
  6.    return userExecutorFromConstructor;
  7.  return shutdownOnClose(WithSubmissionTrace.wrap(newThreadPoolNamed("user thread %d", count)), closer);
  8. }

代码示例来源：origin: jclouds/legacy-jclouds

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_IO_WORKER_THREADS)
  4. ListeningExecutorService provideListeningIOExecutorService(@Named(PROPERTY_IO_WORKER_THREADS) int count,
  5.    Closer closer) { // NO_UCD
  6.  if (ioExecutorFromConstructor != null)
  7.    return ioExecutorFromConstructor;
  8.  return shutdownOnClose(WithSubmissionTrace.wrap(newThreadPoolNamed("i/o thread %d", count)), closer);
  9. }

代码示例来源：origin: org.jclouds/jclouds-core

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_IO_WORKER_THREADS)
  4. ListeningExecutorService provideListeningIOExecutorService(@Named(PROPERTY_IO_WORKER_THREADS) int count,
  5.    Closer closer) { // NO_UCD
  6.  if (ioExecutorFromConstructor != null)
  7.    return ioExecutorFromConstructor;
  8.  return shutdownOnClose(WithSubmissionTrace.wrap(newThreadPoolNamed("i/o thread %d", count)), closer);
  9. }

代码示例来源：origin: io.cloudsoft.jclouds/jclouds-core

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_IO_WORKER_THREADS)
  4. ListeningExecutorService provideListeningIOExecutorService(@Named(PROPERTY_IO_WORKER_THREADS) int count,
  5.    Closer closer) { // NO_UCD
  6.  if (ioExecutorFromConstructor != null)
  7.    return ioExecutorFromConstructor;
  8.  return shutdownOnClose(WithSubmissionTrace.wrap(newThreadPoolNamed("i/o thread %d", count)), closer);
  9. }

代码示例来源：origin: io.cloudsoft.jclouds/jclouds-core

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_USER_THREADS)
  4. ListeningExecutorService provideListeningUserExecutorService(@Named(PROPERTY_USER_THREADS) int count, Closer closer) { // NO_UCD
  5.  if (userExecutorFromConstructor != null)
  6.    return userExecutorFromConstructor;
  7.  return shutdownOnClose(WithSubmissionTrace.wrap(newThreadPoolNamed("user thread %d", count)), closer);
  8. }

代码示例来源：origin: com.amysta.jclouds/jclouds-core

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_SCHEDULER_THREADS)
  4. final ListeningScheduledExecutorService provideListeningScheduledExecutorService(
  5.    @Named(PROPERTY_SCHEDULER_THREADS) int count, Closer closer) {
  6.  return shutdownOnClose(WithSubmissionTrace.wrap(newScheduledThreadPoolNamed("scheduler thread %d", count)),
  7.     closer);
  8. }

代码示例来源：origin: io.cloudsoft.jclouds/jclouds-core

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_SCHEDULER_THREADS)
  4. ListeningScheduledExecutorService provideListeningScheduledExecutorService(
  5.    @Named(PROPERTY_SCHEDULER_THREADS) int count, Closer closer) {
  6.  return shutdownOnClose(WithSubmissionTrace.wrap(newScheduledThreadPoolNamed("scheduler thread %d", count)),
  7.     closer);
  8. }

代码示例来源：origin: Nextdoor/bender

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_SCHEDULER_THREADS)
  4. final ListeningScheduledExecutorService provideListeningScheduledExecutorService(
  5.    @Named(PROPERTY_SCHEDULER_THREADS) int count, Closer closer) {
  6.  return shutdownOnClose(WithSubmissionTrace.wrap(newScheduledThreadPoolNamed("scheduler thread %d", count)),
  7.     closer);
  8. }

代码示例来源：origin: org.jclouds/jclouds-core

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_SCHEDULER_THREADS)
  4. ListeningScheduledExecutorService provideListeningScheduledExecutorService(
  5.    @Named(PROPERTY_SCHEDULER_THREADS) int count, Closer closer) {
  6.  return shutdownOnClose(WithSubmissionTrace.wrap(newScheduledThreadPoolNamed("scheduler thread %d", count)),
  7.     closer);
  8. }

代码示例来源：origin: com.amysta.jclouds/jclouds-core

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_USER_THREADS)
  4. final ListeningExecutorService provideListeningUserExecutorService(@Named(PROPERTY_USER_THREADS) int count, Closer closer) { // NO_UCD
  5.  if (userExecutorFromConstructor != null)
  6.    return userExecutorFromConstructor;
  7.  return shutdownOnClose(WithSubmissionTrace.wrap(newThreadPoolNamed("user thread %d", count)), closer);
  8. }

代码示例来源：origin: apache/jclouds

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_USER_THREADS)
  4. final ListeningExecutorService provideListeningUserExecutorService(@Named(PROPERTY_USER_THREADS) int count, Closer closer) { // NO_UCD
  5.  if (userExecutorFromConstructor != null)
  6.    return userExecutorFromConstructor;
  7.  return shutdownOnClose(WithSubmissionTrace.wrap(newThreadPoolNamed("user thread %d", count)), closer);
  8. }

代码示例来源：origin: Nextdoor/bender

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_USER_THREADS)
  4. final ListeningExecutorService provideListeningUserExecutorService(@Named(PROPERTY_USER_THREADS) int count, Closer closer) { // NO_UCD
  5.  if (userExecutorFromConstructor != null)
  6.    return userExecutorFromConstructor;
  7.  return shutdownOnClose(WithSubmissionTrace.wrap(newThreadPoolNamed("user thread %d", count)), closer);
  8. }

代码示例来源：origin: apache/jclouds

  1. @Provides
  2. @Singleton
  3. @Named(PROPERTY_SCHEDULER_THREADS)
  4. final ListeningScheduledExecutorService provideListeningScheduledExecutorService(
  5.    @Named(PROPERTY_SCHEDULER_THREADS) int count, Closer closer) {
  6.  return shutdownOnClose(WithSubmissionTrace.wrap(newScheduledThreadPoolNamed("scheduler thread %d", count)),
  7.     closer);
  8. }

代码示例来源：origin: jclouds/legacy-jclouds

  1. public static ListeningExecutorService currentRequestExecutorService() {
  2.  ThreadFactory factory = checkNotNull(ThreadManager.currentRequestThreadFactory(),
  3.     "ThreadManager.currentRequestThreadFactory()");
  4.  // GAE requests cannot exceed 10 threads per request
  5.  int maxThreads = 10;
  6.  long keepAlive = ApiProxy.getCurrentEnvironment().getRemainingMillis();
  7.  ExecutorService pool = newScalingThreadPool(0, maxThreads, keepAlive, factory);
  8.  return WithSubmissionTrace.wrap(MoreExecutors.listeningDecorator(pool));
  9. }

代码示例来源：origin: apache/jclouds

  1. public static ListeningExecutorService currentRequestExecutorService() {
  2.  ThreadFactory factory = checkNotNull(ThreadManager.currentRequestThreadFactory(),
  3.     "ThreadManager.currentRequestThreadFactory()");
  4.  // GAE requests cannot exceed 10 threads per request
  5.  int maxThreads = 10;
  6.  long keepAlive = ApiProxy.getCurrentEnvironment().getRemainingMillis();
  7.  ExecutorService pool = newScalingThreadPool(0, maxThreads, keepAlive, factory);
  8.  return WithSubmissionTrace.wrap(MoreExecutors.listeningDecorator(pool));
  9. }

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

WithSubmissionTrace

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com