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

WorkerThreadFactory介绍

[英]A factory to create worker threads with a given name prefix.
[中]用于创建具有给定名称前缀的辅助线程的工厂。

代码示例

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

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

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

/**
 * Creates a new thread factory whose threads will have names using the specified prefix.
 * 
 * @param namePrefix The prefix for the thread names, may be {@code null} or empty to derive the prefix from the
 *            caller's simple class name.
 */
public WorkerThreadFactory( String namePrefix )
{
  this.factory = Executors.defaultThreadFactory();
  this.namePrefix =
    ( ( namePrefix != null && namePrefix.length() > 0 ) ? namePrefix : getCallerSimpleClassName() + '-' )
      + poolIndex.getAndIncrement() + '-';
  threadIndex = new AtomicInteger();
}

代码示例来源：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.apache.maven.resolver/maven-resolver-util

/**
 * Creates a new thread factory whose threads will have names using the specified prefix.
 * 
 * @param namePrefix The prefix for the thread names, may be {@code null} or empty to derive the prefix from the
 *            caller's simple class name.
 */
public WorkerThreadFactory( String namePrefix )
{
  this.factory = Executors.defaultThreadFactory();
  this.namePrefix =
    ( ( namePrefix != null && namePrefix.length() > 0 ) ? namePrefix : getCallerSimpleClassName() + '-' )
      + POOL_INDEX.getAndIncrement() + '-';
  threadIndex = new AtomicInteger();
}

代码示例来源：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.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;
}