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

Threads.daemonThreadsNamed介绍

[英]Creates a ThreadFactory that creates named daemon threads. using the specified naming format.
[中]创建创建命名守护进程线程的线程工厂。使用指定的命名格式。

代码示例

代码示例来源：origin: prestodb/presto

@Provides
@Singleton
@ForTransactionManager
public static ExecutorService createTransactionFinishingExecutor()
{
  return newCachedThreadPool(daemonThreadsNamed("transaction-finishing-%s"));
}

代码示例来源：origin: prestodb/presto

@Provides
@Singleton
@ForAsyncHttp
public static ScheduledExecutorService createAsyncHttpTimeoutExecutor(TaskManagerConfig config)
{
  return newScheduledThreadPool(config.getHttpTimeoutThreads(), daemonThreadsNamed("async-http-timeout-%s"));
}

代码示例来源：origin: prestodb/presto

public TestScanFilterAndProjectOperator()
{
  executor = newCachedThreadPool(daemonThreadsNamed("test-executor-%s"));
  scheduledExecutor = newScheduledThreadPool(2, daemonThreadsNamed("test-scheduledExecutor-%s"));
}

代码示例来源：origin: prestodb/presto

@BeforeClass
public void setUp()
{
  executor = newCachedThreadPool(daemonThreadsNamed("test-executor-%s"));
  scheduledExecutor = newScheduledThreadPool(2, daemonThreadsNamed("test-scheduledExecutor-%s"));
}

代码示例来源：origin: prestodb/presto

@Provides
@Singleton
@ForAsyncHttp
public static ExecutorService createAsyncHttpResponseCoreExecutor()
{
  return newCachedThreadPool(daemonThreadsNamed("async-http-response-%s"));
}

代码示例来源：origin: prestodb/presto

@Provides
@Singleton
@ForStatementResource
public static ScheduledExecutorService createStatementTimeoutExecutor(TaskManagerConfig config)
{
  return newScheduledThreadPool(config.getHttpTimeoutThreads(), daemonThreadsNamed("statement-timeout-%s"));
}

代码示例来源：origin: prestodb/presto

@BeforeClass
public void setUp()
{
  executor = newCachedThreadPool(daemonThreadsNamed("test-executor-%s"));
  scheduledExecutor = newScheduledThreadPool(2, daemonThreadsNamed("test-scheduledExecutor-%s"));
}

代码示例来源：origin: prestodb/presto

@Provides
@Singleton
@ForStatementResource
public static ExecutorService createStatementResponseCoreExecutor()
{
  return newCachedThreadPool(daemonThreadsNamed("statement-response-%s"));
}

代码示例来源：origin: prestodb/presto

@Provides
@Singleton
@ForExchange
public static ScheduledExecutorService createExchangeExecutor(ExchangeClientConfig config)
{
  return newScheduledThreadPool(config.getClientThreads(), daemonThreadsNamed("exchange-client-%s"));
}

代码示例来源：origin: prestodb/presto

@BeforeClass
public void setUp()
{
  executor = newCachedThreadPool(daemonThreadsNamed("test-executor-%s"));
  scheduledExecutor = newScheduledThreadPool(2, daemonThreadsNamed("test-scheduledExecutor-%s"));
}

代码示例来源：origin: prestodb/presto

@Inject
public IndexLookup(Connector connector, ColumnCardinalityCache cardinalityCache)
{
  this.connector = requireNonNull(connector, "connector is null");
  this.cardinalityCache = requireNonNull(cardinalityCache, "cardinalityCache is null");
  // Create a bounded executor with a pool size at 4x number of processors
  this.coreExecutor = newCachedThreadPool(daemonThreadsNamed("cardinality-lookup-%s"));
  this.executorService = new BoundedExecutor(coreExecutor, 4 * Runtime.getRuntime().availableProcessors());
}

代码示例来源：origin: prestodb/presto

@BeforeClass
public void setUp()
{
  stateNotificationExecutor = newScheduledThreadPool(5, daemonThreadsNamed("test-%s"));
}

代码示例来源：origin: prestodb/presto

@BeforeClass
public void setUp()
{
  executor = newCachedThreadPool(daemonThreadsNamed("test-executor-%s"));
  scheduledExecutor = newScheduledThreadPool(2, daemonThreadsNamed("test-scheduledExecutor-%s"));
}

代码示例来源：origin: prestodb/presto

@ForHiveClient
@Singleton
@Provides
public ExecutorService createHiveClientExecutor(HiveConnectorId hiveClientId)
{
  return newCachedThreadPool(daemonThreadsNamed("hive-" + hiveClientId + "-%s"));
}

代码示例来源：origin: prestodb/presto

@BeforeClass
public void setUp()
{
  stateNotificationExecutor = newScheduledThreadPool(5, daemonThreadsNamed("test-%s"));
}

代码示例来源：origin: prestodb/presto

@BeforeClass
public void setUp()
{
  notificationExecutor = newCachedThreadPool(daemonThreadsNamed("local-query-runner-executor-%s"));
  yieldExecutor = newScheduledThreadPool(2, daemonThreadsNamed("local-query-runner-scheduler-%s"));
}

代码示例来源：origin: prestodb/presto

@BeforeClass
public void setupClass()
{
  executor = newCachedThreadPool(daemonThreadsNamed("hive-%s"));
}

代码示例来源：origin: prestodb/presto

@BeforeClass
public void setUp()
{
  scheduledExecutor = newScheduledThreadPool(2, daemonThreadsNamed("test-scheduledExecutor-%s"));
}

代码示例来源：origin: prestodb/presto

@BeforeClass
public void setUp()
{
  executor = newCachedThreadPool(daemonThreadsNamed("test-executor-%s"));
  scheduledExecutor = newScheduledThreadPool(2, daemonThreadsNamed("test-scheduledExecutor-%s"));
}

代码示例来源：origin: prestodb/presto

@BeforeClass
public void setUp()
{
  executor = newCachedThreadPool(daemonThreadsNamed("hive-%s"));
}