多线程 System.setErr() 的正确方法？

Question

所以我有一个使用固定线程池来执行一些代码的 Java 应用程序。此代码包括使用输出到 System.err 的第三方库。当我让这段代码执行单线程时，我将 System.err “重定向”到了 PrintStream，最终打印到 log4j 日志。基本上是这样的：

 PrintStream oldErr = System.err;
 System.setErr(new PrintStream(/* custom logging stream here */));

 try
 {
     // do computationally expensive task here
 }
 finally
 {
     System.setErr(oldErr);
 }

按预期工作。输出打印到日志文件而不是控制台，我可以通过更改我的 log4j 配置来完全删除输出。完美。

当我开始添加多线程时，我做了一些研究并遇到了这个 SO 问题：In a multithreaded Java program, does each thread have its own copy of System.out?，这意味着我应该在启动线程池之前执行一次 System.setErr() 并且我已经准备好了.只是情况似乎并非如此。我的代码现在看起来像这样：

 PrintStream oldErr = System.err;
 System.setErr(new PrintStream(/* custom logging stream here */));

 ExecutorService threadPool = Executors.newFixedThreadPool(maxThreadCount);

 try
 {
     // shove computationally expensive task off to a thread
     //   using threadPool.execute()
 }
 finally
 {
     System.setErr(oldErr);
 }

但是，在启动线程池之前调用 System.setErr() 的效果为零。线程都将它们的输出打印到 System.err，就好像我根本没有进行调用一样。呸！

我还尝试让线程在执行它们的任务时调​​用 System.setErr()，但是有一些明显的竞争条件问题 - 间歇性输出到控制台，以及一般的肮脏感。在一次测试运行中，它甚至看起来像是死锁了。

我错过了一些简单的东西吗？ FWIW，这是我的 JVM 详细信息：

java version "1.6.0_21"
Java(TM) SE Runtime Environment (build 1.6.0_21-b07)
Java HotSpot(TM) 64-Bit Server VM (build 17.0-b17, mixed mode)

谢谢。

编辑：我的问题基本上已通过接受的答案解决，但为了完整起见，我想补充一点，我无法使用 Futures 和 get() 解决我的特殊情况。我的个人任务消耗大量 RAM，但持续时间各不相同，因此我不得不使用Java: ExecutorService that blocks on submission after a certain queue size 的答案中概述的小型阻塞队列。我基本上陷入了认为newFixedThreadPool() 中的默认设置适用于我的情况的陷阱，而实际上它们并没有，而布赖恩的回答有助于揭露这些错误的假设。谢谢布赖恩！

Answer 1

以下 SSCCE 完全符合您的要求：

public class App
{
    public static void main(String[] args) throws FileNotFoundException, InterruptedException, ExecutionException 
    {
        PrintStream oldErr = System.err;
        System.setErr(new PrintStream(new File("test")));

        ExecutorService threadPool = Executors.newFixedThreadPool(5);
        List<Future<?>> fList = new LinkedList<Future<?>>();
        for (int i = 0; i < 5; i++)
        {
            fList.add(threadPool.submit(new Runnable() {

                @Override
                public void run()
                {
                    System.err.println("This is to the err stream");
                }

            }));
        }

        for (Future<?> f : fList)
        {
            f.get();
        }

        threadPool.shutdown();

        System.setErr(oldErr);
        System.err.println("This is to the err stream");
    }
}

运行此示例后，文件“test”包含 5 行，每行都说“这是到 err 流”，最后在控制台上打印了一行。

您显示的代码 sn-p 在 finally 块中调用 System.setErr(oldErr); ...您是否等待在该 try 块中完成所有任务？

如果不是，它会解释您在 cmets 中所做的声明，即 “我会看到输出片段打印到 System.err 并且片段打印到我的日志文件” ...这几乎就是您的意思会发生的。 .submit() 是一个非阻塞调用，返回一个Future；您正在运行任务时重置流。