ExecutorService线程未继承的InheritableThreadLocal值

Question

import java.util.concurrent.Executors
import scala.concurrent.{ExecutionContext, Future}

object TestInheritableThreadLocal {

  def main(args: Array[String]): Unit = {

    implicit val ec = ExecutionContext.fromExecutor(Executors.newFixedThreadPool(2))

    val tl: InheritableThreadLocal[String] = new InheritableThreadLocal[String]()
    tl.set("InitialValue")

    Future {
      println("111 " + Thread.currentThread() + tl.get())
      Future {
        println("222 " + Thread.currentThread() + tl.get())
      }
    }
    Thread.sleep(3000)

    Future {
      tl.set("NewInitialValue")
      println("333 " + Thread.currentThread() + tl.get())
      Future {
        println("444 " + Thread.currentThread() + tl.get())
      }
      Thread.sleep(3000)
    }
  }
}

111 Thread[pool-1-thread-1,5,main]InitialValue
222 Thread[pool-1-thread-2,5,main]InitialValue
333 Thread[pool-1-thread-1,5,main]NewInitialValue
444 Thread[pool-1-thread-2,5,main]InitialValue

是什么导致了这个问题，如何解决？

Answer 1

当您无法控制线程的创建时，不应该依赖InheritableThreadLocal。javadoc声明：

[...]当创建子线程时，子线程接收父线程具有值的所有可继承线程局部变量的初始值。

在您的示例中，线程是由executors.NewFixedThreadPool(2)返回的executorService创建的

然后提交第三个任务333，覆盖InheritableThreadLocal的值并打印它。当您提交第四个任务444时，ExecutorService使用现有线程来执行它。该线程已经有一个值，是以前继承的。

如何解决

在不知道自己想做什么的情况下，很难回答这个问题。但是，如果您想有效地使用InheritableThreadLocal，这一切都归结为了解和控制线程的创建，以及继承链。