并行计算函数中不能调用date::as.date
KAnalysisNum <- function(i){
Ks <- KList[i,2]
StockFileName <- KList[i,1]
Ks <- as.data.frame(Ks)
xtsKs <- xts::xts(Ks[,-c(1)], order.by=date::as.date(Ks$Date))
tradeResult <- 1 #CreateTradeResult(xtsKs)
return(tradeResult)
}
#KList <- KList.shDayKList
cl.cores <- detectCores()
cl <- makeCluster(cl.cores)
registerDoParallel(cl)
clusterExport(cl, "KList")
# 并行计算方式
system.time({
res <- parLapply(cl, 1:length(KList)/2, KAnalysisNum)
});
stopCluster(cl)