List<byte[]> outputBytes = []
GParsPool.withPool( ) {
            outputBytes = events.collectParallel{
                depositNoticeService.getDepositNotice( it.id )
            }
        }

我想为每个线程命名,以便可以在日志记录中对其进行监视,但是我看不到任何有关如何到达那里的文档。

最佳答案

尝试获取当前线程,然后可以更改或获取它的选项:

Thread.currentThread().getName()
Thread.currentThread().setName("NEW NAME")

我正在使用执行程序,下面的示例对我有用:
import java.util.concurrent.*
import javax.annotation.*


def threadExecute = Executors.newSingleThreadExecutor()
threadExecute.execute {
        log.info(Thread.currentThread().getName())
        log.info(Thread.currentThread().setName("NEW NAME"))
        log.info(Thread.currentThread().getName())
 }
 threadExecute.shutdown()

关于multithreading - gpars,命名线程,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/33103339/

10-13 06:24