结合使用InheritableThreadLocal和ThreadPoolExecutor或不重用线程的ThreadPoolExecutor

Question

我正在尝试同时使用InheritableThreadLocal和ThreadPoolExecutor。

由于ThreadPoolExecutor每个池（毕竟是一个池）都将线程重用，这意味着InheritableThreadLocal无法正常工作，因此出现了故障。现在这个问题对我来说似乎很明显，但要追踪它尤为困难。

我InheritableThreadLocal这样使用，以便几个顶级进程中的每个进程都有自己的数据库连接以及它产生的任何子进程。我不只是使用一个共享的连接池，因为在提交数据库和/或准备大量重复使用的PreparedStatement之前，每个顶级进程都会对其连接进行很多多步骤工作。

我ThreadPoolExecutor在这些顶级流程之间使用了共享，因为某些行为需要控制。例如，即使我可能正在运行4个顶级进程，我一次也只能有一个进程写入数据库（或者系统需要使用其他共享资源）。因此，我将在顶层进程中创建一个Runnable并将其发送给共享进程ThreadPoolExecutor，以确保在整个系统中同时运行的进程不超过一个（或两个或三个）。

问题在于，由于为ThreadPoolExecutor线程池重用了其线程，因此，该线程将
InheritableThreadLocal选择在该池中运行的原始值，而不是将Runnable发送到的顶级进程中的值ThreadPoolExecutor。

• 有什么方法可以强制工作池中的工作池ThreadPoolExecutor使用在InheritableThreadLocal创建Runnable的进程的上下文中使用的值，而不是在重用线程池的上下文中使用该值？

• 或者，是否有任何实现在ThreadPoolExecutor每次启动新的Runnable时创建一个新线程？就我的目的而言，我只关心将同时运行的线程数控制到固定大小。

• 人们对我有什么其他解决方案或建议，可以完成上述工作？

（虽然我意识到我可以通过将数据库连接从类到类再传递到子线程再到子线程来解决问题，就像某种社区自行车一样，但我想避免这种情况。）

关于StackOverflow，InheritableThreadLocal和线程池，还有一个先前的问题也可以解决此问题。但是，解决该问题的方法似乎是InheritableThreadLocal的用例很差，我认为这不适用于我的情况。

感谢您的任何想法。

Answer 1

为什么不使用ThreadPoolExecutor保护共享资源，而不是使用java.util.concurrent.Semaphore？您创建的子任务将在其自己的线程中运行完成，但仅在从信号量获得许可后才能完成，当然，完成后释放许可。