我正在使用ExecutorService使用clojure并行执行我的请求。代码如下:
(let [pool (Executors/newFixedThreadPool 6)
tasks #(doseq [{:keys [msisdn repay_time loan_request_id transaction_amount repayment_type]} (fetch-data)]
(util/send-notification msisdn loan_request_id (str repay_time) repayment_type transaction_amount)
)
task-res (.submit pool tasks)]
(.get task-res))
我需要一种记录当前工作线程的方法。请协助。
要获取当前正在运行的线程,请使用 java Thread
类中的currentThread
方法,如下所示:
(.getName (Thread/currentThread))