Skip to main content

Utility which distributes a task across a fixed number of processes, and collates the output, for better utilization of multiprocessing

Project description

Disttask is a utility which provides the ability to distribute a task across a fixed number of processes, for better utilization of multiprocessing.

Use it with existing single-threaded/process tools and scripts to take full advantage of your computer’s resources.

Provides the ability to distribute a task across a fixed number of processes, for better utilization of multiprocessing.

Usage

Usage: ./disttask [cmd] [concurrent tasks] [argset]

Use a %s in [cmd] where you want the args to go. use %d for the pipe number.

To run a list of commands, make ‘%s’ be your full command.

If argset is ‘--’, the items will be read from stdin instead of providing the arguments to disttask.

Execution will start immediately, so you can have disttask manage processing items that another program is feeding in.

Disttask version 2.0.0

The application runs at most “concurrent task” number of processes (good to match total number of processors available to this number - 1). It captures stdout and stderr to ensure that any output is not intertwined between the applications. The output is written in whole upon completion of each task.

Each command should specify a “%s” to where each argument will go (one argument from @argset per application). To feed entire commands, use simply “%s” as the “cmd” and provide the commands in your “argset”. The commands are executed by a shell, and thus can contain shell expressions.

“%d” is also available as the pipe number, which can be used to differentiate the running processes.

You can also have a program or file pipe output to disttask, by providing ‘--’ as the argset. Disttask will run and read from stdin, treating each line as an argset item, and will terminate when stdin has been closed and all subprocesses have completed.

Examples

Use disttask to connect to various hosts in parallel and execute commands:

disttask “echo -n ‘pipe %d: ‘ && ssh root@%s hostname” 2 “host1” “host2” “host3” “host4”

pipe 0: host1

pipe 1: host2

pipe 0: host3

pipe 1: host4

Run pyflakes, using 10 simultaneous processes, on all python files in subdirectories (requires shopt -s globstar. Notice the backticks, not single-quotes.)

disttask “pyflakes %s” 10 echo **/*.py

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

disttask-2.0.0.tar.gz (3.9 kB view details)

Uploaded Source

File details

Details for the file disttask-2.0.0.tar.gz.

File metadata

  • Download URL: disttask-2.0.0.tar.gz
  • Upload date:
  • Size: 3.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No

File hashes

Hashes for disttask-2.0.0.tar.gz
Algorithm Hash digest
SHA256 86d426d531f963f899ac31d5b7b74b845002ff824846fba2107d241321584b7a
MD5 fdb0e125e5011c05766f83e8bc292520
BLAKE2b-256 f41aad950640880e62ff1de47e84b3ed0e0d1890e801a743cda4ce079bf1d881

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page