R中的多核和data.table

Question

我試圖使用multicore函數parallel與data.table，我無法完全想出正確的方法來做到這一點。代碼：

require(multicore) 
require(data.table) 
dtb = data.table(a=1:10, b=1:2) 
x = dtb[,parallel(a+1),by=b] 

> x 
    b pid fd 
1: 1 12243 3 
2: 1 12243 6 
3: 2 12247 4 
4: 2 12247 8 

我想呼籲這collect()但這些都不再parallel對象。應該怎麼做？

Answer 1

我覺得這是線沿線的你想要什麼：

collect(dtb[, list(jobs = list(parallel(a+1))), by = b][, jobs]) 

你沒有parallel對象的任何越來越不能運行collect是因爲你把它們轉換到原因一個list，而不是將它們存儲在的列表中，這是我在上面做的。