r - 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 ，而不是将它们存储在列表中，这就是我上面所做的。