Python和R开启多线程2024-09-05

Python 控制多线程

import threading
t1=threading.Thread(target=func, args=(n_real_cells, adata))
t1.start()#启动线程
t1.join()#线程优先

Python的apply并行运算pandarallel模块

from pandarallel import pandarallel
num_cores=4
pandarallel.initialize(progress_bar=True,nb_workers=num_cores)
def sum_fun(a,b):
    print('test'+b)
    return sum([a,a+2,3])

lpd=pd.Series(range(len(pN))).parallel_apply(sum_fun,b='!')

R 控制多线程

    require(parallel)
    cl <- makeCluster(num.cores) #开启多线程
    output2 <- mclapply(as.list(1:length(pN)),
                        FUN = parallel_paramSweep,
                        PCs,
                        sct,mc.cores=num.cores) #设置线程数
     stopCluster(cl) #结束多线程