gpt4 book ai didi

org.eclipse.aether.util.concurrency.WorkerThreadFactory.()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-21 05:23:05 28 4
gpt4 key购买 nike

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

WorkerThreadFactory.<init>介绍

[英]Creates a new thread factory whose threads will have names using the specified prefix.
[中]创建一个新的线程工厂,其线程的名称将使用指定的前缀。

代码示例

代码示例来源:origin: stackoverflow.com

private ExecutorService executor = Executors.newCachedThreadPool(new WorkerThreadFactory());

代码示例来源:origin: org.eclipse.aether/aether-impl

private Executor getExecutor( int threads )
{
  if ( threads <= 1 )
  {
    return new Executor()
    {
      public void execute( Runnable command )
      {
        command.run();
      }
    };
  }
  else
  {
    return new ThreadPoolExecutor( threads, threads, 3, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),
                    new WorkerThreadFactory( null ) );
  }
}

代码示例来源:origin: org.apache.maven.resolver/maven-resolver-impl

private Executor getExecutor( int threads )
{
  if ( threads <= 1 )
  {
    return new Executor()
    {
      public void execute( Runnable command )
      {
        command.run();
      }
    };
  }
  else
  {
    return new ThreadPoolExecutor( threads, threads, 3, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),
                    new WorkerThreadFactory( null ) );
  }
}

代码示例来源:origin: org.eclipse.aether/aether-connector-basic

private Executor getExecutor( Collection<?> artifacts, Collection<?> metadatas )
{
  if ( maxThreads <= 1 )
  {
    return DirectExecutor.INSTANCE;
  }
  int tasks = safe( artifacts ).size() + safe( metadatas ).size();
  if ( tasks <= 1 )
  {
    return DirectExecutor.INSTANCE;
  }
  if ( executor == null )
  {
    executor =
      new ThreadPoolExecutor( maxThreads, maxThreads, 3, TimeUnit.SECONDS,
                  new LinkedBlockingQueue<Runnable>(),
                  new WorkerThreadFactory( getClass().getSimpleName() + '-'
                    + repository.getHost() + '-' ) );
  }
  return executor;
}

代码示例来源:origin: org.apache.maven.resolver/maven-resolver-connector-basic

private Executor getExecutor( Collection<?> artifacts, Collection<?> metadatas )
{
  if ( maxThreads <= 1 )
  {
    return DirectExecutor.INSTANCE;
  }
  int tasks = safe( artifacts ).size() + safe( metadatas ).size();
  if ( tasks <= 1 )
  {
    return DirectExecutor.INSTANCE;
  }
  if ( executor == null )
  {
    executor =
      new ThreadPoolExecutor( maxThreads, maxThreads, 3L, TimeUnit.SECONDS,
                  new LinkedBlockingQueue<Runnable>(),
                  new WorkerThreadFactory( getClass().getSimpleName() + '-'
                    + repository.getHost() + '-' ) );
  }
  return executor;
}

28 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com