如何找到调用threadPool的方法

Question

我在生产应用程序中有一些错误，但我找不到它的原因。我试着找一些日志来找到一个方法，它调用我的method()。但是因为我使用threadPool，我不能只获取Thread.currentThread().getStackTrace()并迭代StackTraceElements，它在ThreadPool之前只显示一些行。如果我使用下一个代码，我将获得我需要的所有方法，但它是如此广泛。在我的测试环境中，只有一次方法调用在文本文件中花费400+ Kb。我认为，在生产中，它会在一秒钟内达到约1 Mb。

private final ExecutorService completableFutureExecutor =
            new ThreadPoolExecutor(10, 2000, 60L, TimeUnit.SECONDS, new SynchronousQueue<>());

public void firstMethod(){

    secondMethod();    
}

private CompletableFuture<Void> secondMethod(){

    return CompletableFuture.supplyAsync(()->method(),threadPool);

}

void method(){
    Map<Thread, StackTraceElement[]> map = Thread.getAllStackTraces();
        for (Thread thread : map.keySet()) {
            printLog(thread);
        }
}
private void printLog(Thread thread) {
        StringBuilder builder = new StringBuilder();
        for (StackTraceElement s : thread.getStackTrace()) {
            builder.append("\n getClass = " + s.getClass());
            builder.append("\n getClassName = " + s.getClassName());
            builder.append("\n getFileName = " + s.getFileName());
            builder.append("\n getLineNumber = " + s.getLineNumber());
            builder.append("\n getMethodName = " + s.getMethodName());
            builder.append("\n  ---------------------------- \n ");
        }
        ownLogger.info("SomeThread = {} ", builder);
    }

如何找到那个叫firstMethod()的secondMethod()？

Answer 1

由于我没有找到任何好的解决方案，我自己就是在CompletableFuture调用之前和之后放置logger

看起来像

Logger beforeAsync= LoggerFactory.getLogger("beforeAsync");
Logger afterAsync= LoggerFactory.getLogger("afterAsync");

private CompletableFuture<Void> secondMethod(){
    printLongerTrace(Thread.currentThread(),beforeAsync);
    return CompletableFuture.supplyAsync(()->method(),threadPool);
}

private void methodWithException(){
    try{
    //do something
    }
    catch(Exception e){ 
      printLongerTrace(e,"methodWithException", afterAsync);
    }
}

public void printLongerTrace(Throwable t, String methodName, Logger ownlogger) {

    if (t.getCause() != null) {
        printLongerTrace(t.getCause(), methodName, fields, ownlogger);
    }
    StringBuilder builder = new StringBuilder();
    builder.append("\n Thread = " + Thread.currentThread().getName());
    builder.append("ERROR CAUSE = " + t.getCause() + "\n");
    builder.append("ERROR MESSAGE = " + t.getMessage() + "\n");

    printLog(t.getStackTrace(), builder);
    ownlogger.info(methodName + "Trace ----- {}", builder);
}

public void printLongerTrace(Thread t, Logger ownlogger) {

    StringBuilder builder = new StringBuilder();
    builder.append("\n Thread = " + Thread.currentThread().getName());

    printLog(t.getStackTrace(), builder);
    ownlogger.info("Trace ----- {}", builder);
}

private StringBuilder printLog(StackTraceElement[] elements, StringBuilder builder) {

    int size = elements.length > 15 ? 15 : elements.length;

    for (int i = 0; i < size; i++) {
        builder.append("Line " + i + " = " + elements[i] + "   with method = " + elements[i].getMethodName() + "\n");
    }
    return builder;
}

printLongerTrace(Throwable t, String methodName, Logger ownlogger)需要在递归时以各种原因打印异常。

printLongerTrace(Thread t, Logger ownlogger)需要在CompletableFuture之前打印哪个方法调用

Answer 2

只需通过调用Thread.dumpStack()来转储堆栈，但这只适用于debugin并且开销很大，因为转储堆栈是cpu密集型的