Skip to main content

Library helps easy write concurrent executed code blocks

Project description

Concurrently

Library helps to easily write concurrent executed code blocks.

Quick example:

import asyncio
from concurrently import concurrently


async def amain(loop):
    """
    How to fetch some web pages with concurrently.
    """
    urls = [  # define pages urls
        'http://test/page_1',
        'http://test/page_2',
        'http://test/page_3',
        'http://test/page_4',
    ]
    results = {}

    # immediately run wrapped function concurrent
    # in 2 thread (asyncio coroutines)
    @concurrently(2)
    async def fetch_urls():
        for url in urls:
            # some function for download page
            page = await fetch_page(url)
            results[url] = page

    # wait until all concurrent threads finished
    await fetch_urls()
    print(results)


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(amain(loop))
Decorator @concurrently makes to main thinks:
  • starts concurrent execution specified count of decorated function

  • returns special waiter object to control the running functions

By default, the code runs as asyncio coroutines, but there are other supported ways to execute, by specifying the argument engine.

Documentation

See https://concurrently.readthedocs.io/

Requirements

Now support only Python 3.5 and above.

Install

From PyPi:

$ pip install concurrently

From local:

# update setuptools
$ pip install 'setuptools >= 30.4'
# do install
$ make install
# or
$ pip install .

Development

Prepare and activate virtual environment like:

$ python3 -m venv .env
# for bash
$ source .env/bin/activate
# for fish
$ . .env/bin/activate.fish

Update pre-install dependencies:

$ pip install 'setuptools >= 30.4'

Install:

$ make install_dev
# or
$ pip install --editable .[develop]

Run tests:

$ make test
# or
$ pytest tests/

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

concurrently-1.1.dev1.tar.gz (9.7 kB view details)

Uploaded Source

Built Distribution

concurrently-1.1.dev1-py3-none-any.whl (14.6 kB view details)

Uploaded Python 3

File details

Details for the file concurrently-1.1.dev1.tar.gz.

File metadata

  • Download URL: concurrently-1.1.dev1.tar.gz
  • Upload date:
  • Size: 9.7 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.3.0 pkginfo/1.7.0 requests/2.25.1 setuptools/53.0.0 requests-toolbelt/0.9.1 tqdm/4.57.0 CPython/3.9.2

File hashes

Hashes for concurrently-1.1.dev1.tar.gz
Algorithm Hash digest
SHA256 f01a5ae71edbb7cd0608d6d2acd9e2d7060bec4ee8b960f96b48db0915bde085
MD5 39e640ab3db80497566757baed3f8cfb
BLAKE2b-256 12bc3dbe6deccd7cb7b512a7a324e29b03b0b724b1a5b91608b611543de51858

See more details on using hashes here.

File details

Details for the file concurrently-1.1.dev1-py3-none-any.whl.

File metadata

  • Download URL: concurrently-1.1.dev1-py3-none-any.whl
  • Upload date:
  • Size: 14.6 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.3.0 pkginfo/1.7.0 requests/2.25.1 setuptools/53.0.0 requests-toolbelt/0.9.1 tqdm/4.57.0 CPython/3.9.2

File hashes

Hashes for concurrently-1.1.dev1-py3-none-any.whl
Algorithm Hash digest
SHA256 e6dfdd2d9b5e4842d1eae96a147153cf634a067afcde5001557d2863be1ad8f2
MD5 4d7e23de504f611878123fd8d44c9b63
BLAKE2b-256 61df67e2e26926126f437efd2ebfebe7de39929906e78d1f47ada2076494e1e6

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