System.setErr（）的正确方法？

Question

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

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

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

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

当我开始添加多线程时，我做了一些研究，遇到了这样一个问题：在多线程Java程序中，每个线程是否都有自己的系统副本。出来这意味着我应该做系统。在启动线程池之前设置一次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);
 }

然而，呼叫系统。启动线程池之前的setErr（）无效。所有线程都将其输出打印到系统。好像我根本没有打过电话似的。该死！

我还尝试了线程调用系统。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的答案中所述，该队列在达到一定队列大小后在提交时阻塞。我基本上陷入了这样一个陷阱：我认为newFixedThreadPool（）中的默认值适用于我的情况，而实际上它们并不适用，而Brian的回答帮助我暴露了这些错误的假设。谢谢Brian！

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行，每行都表示“这是错误流”，最后会向控制台打印另外一行。

您显示的代码片段正在调用System.setErr（oldErr）；在最后块中...您是否在该try块中等待所有任务完成？

如果没有，它将解释您在注释中所做的声明“我会看到输出的片段打印到System.err和片段打印到我的日志文件”...这几乎就是您所期望的。。提交（）是一个非阻塞调用，返回Future；您正在运行任务时重置流。