import parallely instead of future

Author: JonasRieger

DESCRIPTION

@@ -18,7 +18,7 @@ Imports:
 	data.table (>= 1.11.2),
 	dendextend,
 	fs (>= 1.2.0),
-	future,
+	parallelly,
 	lda (>= 1.4.2),
 	parallelMap,
 	progress (>= 1.1.1),

R/LDARep.R

@@ -32,7 +32,7 @@
 #' is called after.
 #' @param ncpus [\code{integer(1)}]\cr
 #' Number of (physical) CPUs to use. If \code{pm.backend} is passed,
-#' default is determined by \code{\link[future]{availableCores}}.
+#' default is determined by \code{\link[parallelly]{availableCores}}.
 #' @param ... additional arguments passed to \code{\link[lda]{lda.collapsed.gibbs.sampler}}.
 #' Arguments will be coerced to a vector of length \code{n}.
 #' Default parameters are \code{alpha = eta = 1/K} and \code{num.iterations = 200}.
@@ -85,7 +85,7 @@ LDARep = function(docs, vocab, n = 100, seeds, id = "LDARep", pm.backend, ncpus,
   }
 
   if (!missing(pm.backend) && !is.null(pm.backend)){
-    if (missing(ncpus) || is.null(ncpus)) ncpus = future::availableCores()
+    if (missing(ncpus) || is.null(ncpus)) ncpus = parallelly::availableCores()
     assert_choice(pm.backend, choices = c("multicore", "socket", "mpi"))
     assert_int(ncpus, lower = 1)
     parallelMap::parallelStart(mode = pm.backend, cpus = ncpus)

R/cosineTopics.R

@@ -28,7 +28,7 @@
 #' is called after.
 #' @param ncpus [\code{integer(1)}]\cr
 #' Number of (physical) CPUs to use. If \code{pm.backend} is passed,
-#' default is determined by \code{\link[future]{availableCores}}.
+#' default is determined by \code{\link[parallelly]{availableCores}}.
 #' @return [\code{named list}] with entries
 #' \describe{
 #'   \item{\code{sims}}{[\code{lower triangular named matrix}] with all pairwise
@@ -68,7 +68,7 @@ cosineTopics = function(topics, progress = TRUE, pm.backend, ncpus){
 
 cosineTopics.parallel = function(topics, pm.backend, ncpus){
   assert_choice(pm.backend, choices = c("multicore", "socket", "mpi"))
-  if (missing(ncpus) || is.null(ncpus)) ncpus = future::availableCores()
+  if (missing(ncpus) || is.null(ncpus)) ncpus = parallelly::availableCores()
   assert_int(ncpus, lower = 1)
 
   N = ncol(topics)

R/jaccardTopics.R

@@ -48,7 +48,7 @@
 #' is called after.
 #' @param ncpus [\code{integer(1)}]\cr
 #' Number of (physical) CPUs to use. If \code{pm.backend} is passed,
-#' default is determined by \code{\link[future]{availableCores}}.
+#' default is determined by \code{\link[parallelly]{availableCores}}.
 #' @return [\code{named list}] with entries
 #' \describe{
 #'   \item{\code{sims}}{[\code{lower triangular named matrix}] with all pairwise
@@ -129,7 +129,7 @@ print.TopicSimilarity = function(x, ...){
 
 jaccardTopics.parallel = function(topics, limit.rel, limit.abs, atLeast, pm.backend, ncpus){
   assert_choice(pm.backend, choices = c("multicore", "socket", "mpi"))
-  if (missing(ncpus) || is.null(ncpus)) ncpus = future::availableCores()
+  if (missing(ncpus) || is.null(ncpus)) ncpus = parallelly::availableCores()
   assert_int(ncpus, lower = 1)
 
   N = ncol(topics)

R/jsTopics.R

@@ -36,7 +36,7 @@
 #' is called after.
 #' @param ncpus [\code{integer(1)}]\cr
 #' Number of (physical) CPUs to use. If \code{pm.backend} is passed,
-#' default is determined by \code{\link[future]{availableCores}}.
+#' default is determined by \code{\link[parallelly]{availableCores}}.
 #' @return [\code{named list}] with entries
 #' \describe{
 #'   \item{\code{sims}}{[\code{lower triangular named matrix}] with all pairwise
@@ -83,7 +83,7 @@ jsTopics = function(topics, epsilon = 1e-6, progress = TRUE, pm.backend, ncpus){
 
 jsTopics.parallel = function(topics, epsilon, pm.backend, ncpus){
   assert_choice(pm.backend, choices = c("multicore", "socket", "mpi"))
-  if (missing(ncpus) || is.null(ncpus)) ncpus = future::availableCores()
+  if (missing(ncpus) || is.null(ncpus)) ncpus = parallelly::availableCores()
   assert_int(ncpus, lower = 1)
 
   N = ncol(topics)

R/rboTopics.R

@@ -40,7 +40,7 @@
 #' is called after.
 #' @param ncpus [\code{integer(1)}]\cr
 #' Number of (physical) CPUs to use. If \code{pm.backend} is passed,
-#' default is determined by \code{\link[future]{availableCores}}.
+#' default is determined by \code{\link[parallelly]{availableCores}}.
 #' @return [\code{named list}] with entries
 #' \describe{
 #'   \item{\code{sims}}{[\code{lower triangular named matrix}] with all pairwise
@@ -83,7 +83,7 @@ rboTopics = function(topics, k, p, progress = TRUE, pm.backend, ncpus){
 
 rboTopics.parallel = function(topics, k, p, pm.backend, ncpus){
   assert_choice(pm.backend, choices = c("multicore", "socket", "mpi"))
-  if (missing(ncpus) || is.null(ncpus)) ncpus = future::availableCores()
+  if (missing(ncpus) || is.null(ncpus)) ncpus = parallelly::availableCores()
   assert_int(ncpus, lower = 1)
 
   N = ncol(topics)