Scala ThreadFactoryBuilder类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Scala›Scala教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Scala中com.google.common.util.concurrent.ThreadFactoryBuilder类的典型用法代码示例。如果您正苦于以下问题：Scala ThreadFactoryBuilder类的具体用法？Scala ThreadFactoryBuilder怎么用？Scala ThreadFactoryBuilder使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了ThreadFactoryBuilder类的2个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Scala代码示例。

示例1: createThreadPool

//设置package包名称以及导入依赖的类
package com.bwsw.sj.engine.core.engine

import java.util.concurrent.{ExecutorService, ExecutorCompletionService, Executors}

import com.bwsw.sj.common.utils.EngineLiterals
import com.google.common.util.concurrent.ThreadFactoryBuilder
import org.slf4j.LoggerFactory


trait TaskRunner {

  private val logger = LoggerFactory.getLogger(this.getClass)
  protected val threadName: String
  private val threadPool: ExecutorService = createThreadPool(threadName)
  protected val executorService = new ExecutorCompletionService[Unit](threadPool)
  protected val blockingQueue: PersistentBlockingQueue = new PersistentBlockingQueue(EngineLiterals.persistentBlockingQueue)

  private def createThreadPool(factoryName: String) = {
    val countOfThreads = 3
    val threadFactory = createThreadFactory(factoryName)

    Executors.newFixedThreadPool(countOfThreads, threadFactory)
  }

  private def createThreadFactory(name: String) = {
    new ThreadFactoryBuilder()
      .setNameFormat(name)
      .build()
  }

  def handleException(exception: Throwable) = {
    logger.error("Runtime exception", exception)
    exception.printStackTrace()
    threadPool.shutdownNow()
    System.exit(-1)
  }
}

开发者ID:bwsw，项目名称:sj-platform，代码行数:38，代码来源:TaskRunner.scala

示例2: SizeScaleThreadPoolExecutorTest

//设置package包名称以及导入依赖的类
package teleporter.integration.concurrent

import java.util.concurrent.TimeUnit

import com.google.common.collect.Queues
import com.google.common.util.concurrent.ThreadFactoryBuilder
import org.scalatest.{FunSuite, Matchers}


class SizeScaleThreadPoolExecutorTest extends FunSuite with Matchers {
  test("size scale thread pool executor") {
    val threshold = 2
    val tasks = 16
    val threadPool = new SizeScaleThreadPoolExecutor(2, 10, threshold, 1, TimeUnit.MILLISECONDS,
      Queues.newLinkedBlockingDeque(),
      new ThreadFactoryBuilder().setNameFormat("size-scale-pool-%d").build())
    for (i ? 1 to tasks) {
      threadPool.submit(new Runnable {
        override def run(): Unit = {
          println(Thread.currentThread().getName)
          Thread.sleep(5 * 1000)
        }
      })
    }
    Thread.sleep(2 * 1000)
    threadPool.getCorePoolSize should be((tasks - 2) / threshold)
    Thread.sleep(15 * 1000)
    threadPool.getCorePoolSize should be(2)
  }
}

开发者ID:huanwuji，项目名称:teleporter，代码行数:31，代码来源:SizeScaleThreadPoolExecutorTest.scala

注：本文中的com.google.common.util.concurrent.ThreadFactoryBuilder类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。