Package: parallelly 1.39.0
parallelly: Enhancing the 'parallel' Package
Utility functions that enhance the 'parallel' package and support the built-in parallel backends of the 'future' package. For example, availableCores() gives the number of CPU cores available to your R process as given by the operating system, 'cgroups' and Linux containers, R options, and environment variables, including those set by job schedulers on high-performance compute clusters. If none is set, it will fall back to parallel::detectCores(). Another example is makeClusterPSOCK(), which is backward compatible with parallel::makePSOCKcluster() while doing a better job in setting up remote cluster workers without the need for configuring the firewall to do port-forwarding to your local computer.
Authors:
parallelly_1.39.0.tar.gz
parallelly_1.39.0.zip(r-4.5)parallelly_1.39.0.zip(r-4.4)parallelly_1.39.0.zip(r-4.3)
parallelly_1.39.0.tgz(r-4.4-x86_64)parallelly_1.39.0.tgz(r-4.4-arm64)parallelly_1.39.0.tgz(r-4.3-x86_64)parallelly_1.39.0.tgz(r-4.3-arm64)
parallelly_1.39.0.tar.gz(r-4.5-noble)parallelly_1.39.0.tar.gz(r-4.4-noble)
parallelly_1.39.0.tgz(r-4.4-emscripten)parallelly_1.39.0.tgz(r-4.3-emscripten)
parallelly.pdf |parallelly.html✨
parallelly/json (API)
NEWS
| # Install 'parallelly' in R: |
| install.packages('parallelly', repos = c('https://henrikbengtsson.r-universe.dev', 'https://cloud.r-project.org')) |
Bug tracker:https://github.com/henrikbengtsson/parallelly/issues
Last updated 14 days agofrom:ede5e2603e (on master). Checks:OK: 8 ERROR: 1. Indexed: yes.
| Target | Result | Date |
|---|---|---|
| Doc / Vignettes | OK | Nov 07 2024 |
| R-4.5-win-x86_64 | OK | Nov 07 2024 |
| R-4.5-linux-x86_64 | ERROR | Nov 07 2024 |
| R-4.4-win-x86_64 | OK | Nov 07 2024 |
| R-4.4-mac-x86_64 | OK | Nov 07 2024 |
| R-4.4-mac-aarch64 | OK | Nov 07 2024 |
| R-4.3-win-x86_64 | OK | Nov 07 2024 |
| R-4.3-mac-x86_64 | OK | Nov 07 2024 |
| R-4.3-mac-aarch64 | OK | Nov 07 2024 |
Exports:as.clusterautoStopClusteravailableConnectionsavailableCoresavailableWorkerscloneNodeconnectionIdcpuLoadfreeConnectionsfreeCoresfreePortisConnectionValidisForkedChildisForkedNodeisLocalhostNodeisNodeAlivekillNodemakeClusterMPImakeClusterPSOCKmakeClusterSequentialmakeNodePSOCKMPIPSOCKSEQserializedSizesupportsMulticore
Dependencies:
Readme and manuals
Help Manual
| Help page | Topics |
|---|---|
| Coerce an Object to a Cluster Object | as.cluster as.cluster.cluster as.cluster.list as.cluster.RichSOCKnode as.cluster.SOCK0node as.cluster.SOCKnode c.cluster |
| Automatically Stop a Cluster when Garbage Collected | autoStopCluster |
| Number of Available and Free Connections | availableConnections freeConnections |
| Get Number of Available Cores on The Current Machine | availableCores |
| Get Set of Available Workers | availableWorkers |
| Create a PSOCK Cluster of R Workers for Parallel Processing | checkNumberOfLocalWorkers makeClusterPSOCK makeNodePSOCK PSOCK |
| Clone one or more nodes | cloneNode |
| Find a TCP port that can be opened | freePort |
| Checks if a Connection is Valid | connectionId isConnectionValid |
| Checks whether or not we are running in a forked child process | isForkedChild |
| Checks whether or not a Cluster Node Runs in a Forked Process | isForkedNode |
| Checks whether or not a Cluster Node Runs on Localhost | isLocalhostNode |
| Check whether or not the cluster nodes are alive | isNodeAlive |
| Terminate one or more cluster nodes using process signaling | killNode |
| Create a Message Passing Interface (MPI) Cluster of R Workers for Parallel Processing | makeClusterMPI MPI |
| Create a "parallel" cluster running sequentially in the current session | makeClusterSequential SEQ |
| Options Used by the 'parallelly' Package | future.availableCores.custom future.availableCores.fallback future.availableCores.methods future.availableCores.system future.availableWorkers.custom future.availableWorkers.methods future.fork.enable future.supportsMulticore.unstable parallelly.availableCores.custom parallelly.availableCores.fallback parallelly.availableCores.methods parallelly.availableCores.min parallelly.availableCores.omit parallelly.availableCores.system parallelly.availableWorkers.custom parallelly.availableWorkers.methods parallelly.debug parallelly.fork.enable parallelly.makeNodePSOCK.connectTimeout parallelly.makeNodePSOCK.rshcmd parallelly.makeNodePSOCK.rshopts parallelly.makeNodePSOCK.setup_strategy parallelly.makeNodePSOCK.socketOptions parallelly.makeNodePSOCK.timeout parallelly.makeNodePSOCK.tries parallelly.makeNodePSOCK.tries.delay parallelly.makeNodePSOCK.useXDR parallelly.makeNodePSOCK.validate parallelly.maxWorkers.localhost parallelly.options parallelly.supportsMulticore.disableOn parallelly.supportsMulticore.unstable R_FUTURE_AVAILABLECORES_FALLBACK R_FUTURE_AVAILABLECORES_SYSTEM R_FUTURE_FORK_ENABLE R_FUTURE_SUPPORTSMULTICORE_UNSTABLE R_PARALLELLY_AVAILABLECORES_FALLBACK R_PARALLELLY_AVAILABLECORES_MIN R_PARALLELLY_AVAILABLECORES_OMIT R_PARALLELLY_AVAILABLECORES_SYSTEM R_PARALLELLY_FORK_ENABLE R_PARALLELLY_MAKENODEPSOCK_CONNECTTIMEOUT R_PARALLELLY_MAKENODEPSOCK_RSHCMD R_PARALLELLY_MAKENODEPSOCK_RSHOPTS R_PARALLELLY_MAKENODEPSOCK_SETUP_STRATEGY R_PARALLELLY_MAKENODEPSOCK_SOCKETOPTIONS R_PARALLELLY_MAKENODEPSOCK_TIMEOUT R_PARALLELLY_MAKENODEPSOCK_TRIES R_PARALLELLY_MAKENODEPSOCK_TRIES_DELAY R_PARALLELLY_MAKENODEPSOCK_USEXDR R_PARALLELLY_MAKENODEPSOCK_VALIDATE R_PARALLELLY_SUPPORTSMULTICORE_DISABLEON R_PARALLELLY_SUPPORTSMULTICORE_UNSTABLE |
| Calculate the size of an R object when it is serialized | serializedSize |
| Check If Forked Processing ("multicore") is Supported | supportsMulticore |
