如何找到调用threadPool的方法

Question

我在生产应用程序中有一些错误，但找不到原因。我尝试获取一些日志以找到调用我的 method() 的方法。但是因为我使用 threadPool，所以我不能只获取 Thread.currentThread().getStackTrace() 并遍历 StackTraceElements，它只显示 ThreadPool 之前的一些行。如果我使用下一个代码，我会得到我需要的每一个方法，但它是如此广泛。在我的测试环境中，文本文件中只有 1 次方法调用花费 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

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

Answer 2

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

看起来像

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

之前打印哪个方法调用

如何找到调用threadPool的方法

How to find method which call threadPool

java

stack-trace