0

在 Java 中,我使用 FutureTask 通过 Executor 异步运行 Callable。为了检查调用线程是否发生错误,我需要从 Callable 中抛出潜在的异常。但是,这会导致堆栈跟踪打印到 System.out(我已调试,这发生在 LockSupport.unpark(Thread) 的 Unsafe.unpark(Thread) 内部)。

有什么想法可以防止这种情况吗?

我之前(通过 SLF4J)已经将异常记录到真正的记录器中,并且从不希望在 System.out 上直接堆栈跟踪。

更新:我想我已经指出了相关信息,但要澄清所有问题:这个测试用例可以重现问题(方法 testTransferStreamAsyncCallbackFail()): https ://github.com/mmm/util/blob/master/io/ src/test/java/net/sf/mmm/util/io/base/StreamUtilTest.java

使用的实现是这样的:

public AsyncTransferrer transferAsync(InputStream inStream,OutputStream outStream,布尔keepOutStreamOpen,TransferCallback回调){
    StreamTransferrer transferrer = new StreamTransferrer(inStream, outStream, keepOutStreamOpen, callback);
    AsyncTransferrerImpl 任务 = new AsyncTransferrerImpl(transferrer);
    this.executor.execute(task);
    返回任务;
  }

我通过 eniter 代码进行了调试,它绝对不是我的代码记录到控制台。正如我试图解释的那样,这是在 JDK 中完成的。

附加更新以回答问题:

我正在使用的执行器是 Executors.defaultThreadFactory() 正如您在此处看到的: https ://github.com/mmm/util/blob/master/core/src/main/java/net/sf/mmm/util/concurrent /base/SimpleExecutor.java#L30 https://github.com/mmm/util/blob/master/io/src/main/java/net/sf/mmm/util/io/base/StreamUtilImpl.java#L165

输出是我在测试中从 Callable 中抛出的异常的堆栈跟踪:

java.util.concurrent.ExecutionException: net.sf.mmm.util.io.api.RuntimeIoException: IO: 复制数据时发生意外错误!
23355443-dae9-4f4e-87a2-fe38b8a3d513
    在 java.util.concurrent.FutureTask.report(FutureTask.java:122)
    在 java.util.concurrent.FutureTask.get(FutureTask.java:192)
    在 net.sf.mmm.util.io.base.StreamUtilImpl$AsyncTransferrerImpl.get(StreamUtilImpl.java:1)
    在 net.sf.mmm.util.io.base.StreamUtilTest.testTransferStreamAsyncCallbackFail(StreamUtilTest.java:171)
    在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    在 java.lang.reflect.Method.invoke(Method.java:498)
    在 org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
    在 org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    在 org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
    在 org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    在 org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
    在 org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
    在 org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
    在 org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    在 org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    在 org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    在 org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    在 org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    在 org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    在 org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
    在 org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
    在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:678)
    在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
    在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
原因:net.sf.mmm.util.io.api.RuntimeIoException: IO: 复制数据时发生意外错误!
23355443-dae9-4f4e-87a2-fe38b8a3d513
    在 net.sf.mmm.util.io.base.StreamUtilImpl$BaseTransferrer.transfer(StreamUtilImpl.java:533)
    在 net.sf.mmm.util.io.base.StreamUtilImpl$BaseTransferrer.call(StreamUtilImpl.java:583)
    在 net.sf.mmm.util.io.base.StreamUtilImpl$BaseTransferrer.call(StreamUtilImpl.java:1)
    在 java.util.concurrent.FutureTask.run(FutureTask.java:266)
    在 java.lang.Thread.run(Thread.java:745)
引起:java.io.IOException:这是一个测试!
    在 net.sf.mmm.util.io.base.StreamUtilTest.testTransferStreamAsyncCallbackFail(StreamUtilTest.java:155)
    在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    在 java.lang.reflect.Method.invoke(Method.java:498)
    在 org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
    在 org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    在 org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
    在 org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    在 org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
    在 org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
    在 org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
    在 org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    在 org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    在 org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    在 org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    在 org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    在 org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    在 org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
    在 org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
    在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:678)
    在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
    在 org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
4

0 回答 0