我正在閱讀有關Executors.newWorkStealingPool 的內容,并且想知道如何設置它。我的線程將從LinkedBlockingQueue中拉出,因此將連續運行(除非在“take”調用處被阻止)。假設我不知道運行此代碼的主機上將提供多少個內核。我如何知道要添加多少個 Runnable 對象實例?Runnable processRecord = () -> { try { consumeRecord(blockingQueue.take()); } catch (InterruptedException e) { e.printStackTrace(); }public void setup() { ExecutorService workPool = Executors.newWorkStealingPool();-----> 我傳入了多少個線程實例? workPool.submit(processRecord);}更有可能的是 - 我如何(正確)使用這個線程構造?
1 回答

慕的地10843
TA貢獻1785條經驗 獲得超8個贊
Runnables
提交到工作竊取池 ( ForkJoinPool
) 會執行一次(就像在任何其他線程池中一樣)。
對于示例實現,processRecord
您需要為中的每個元素提交一個blockingQueue
添加回答
舉報
0/150
提交
取消