我正在閱讀有關(guān)Executors.newWorkStealingPool 的內(nèi)容，并且想知道如何設(shè)置它。我的線程將從LinkedBlockingQueue中拉出，因此將連續(xù)運行（除非在“take”調(diào)用處被阻止）。假設(shè)我不知道運行此代碼的主機上將提供多少個內(nèi)核。我如何知道要添加多少個 Runnable 對象實例？Runnable processRecord = () -> { try { consumeRecord(blockingQueue.take()); } catch (InterruptedException e) { e.printStackTrace(); }public void setup() { ExecutorService workPool = Executors.newWorkStealingPool();-----> 我傳入了多少個線程實例？ workPool.submit(processRecord);}更有可能的是 - 我如何（正確）使用這個線程構(gòu)造？
1 回答
慕的地10843
TA貢獻1785條經(jīng)驗 獲得超8個贊
Runnables提交到工作竊取池 ( ForkJoinPool) 會執(zhí)行一次（就像在任何其他線程池中一樣）。
對于示例實現(xiàn)，processRecord您需要為中的每個元素提交一個blockingQueue
添加回答
舉報
0/150
提交
取消