{ "info": { "author": "Wojciech Kolodziej", "author_email": "vojtekkol@o2.pl", "bugtrack_url": null, "classifiers": [ "License :: OSI Approved :: MIT License", "Operating System :: OS Independent", "Programming Language :: Python :: 3" ], "description": "# queuing\nMultithreating producent-consumer solution\n\nExample\n```python\nimport queuing\nimport time\nimport logging\n\nlogging.basicConfig(level=logging.DEBUG, format='%(asctime)s [%(levelname)5s] %(name)s %(message)s')\n\n\n@queuing.consumer(instances=5)\ndef m1(no):\n time.sleep(1)\n print(\"m1 {}\".format(no))\n queuing.broker.send('m2', {\n 'no': no,\n 'sqno': no * no,\n })\n [queuing.broker.send('m3', {\n 'no': no,\n }) for i in range(0, 10)]\n\n\n@queuing.consumer(instances=2)\ndef m2(no, sqno):\n time.sleep(2)\n print(\"m2 {} {}\".format(no, sqno))\n\n\n@queuing.consumer(instances=1)\ndef m3(no):\n print(\"m3 {}\".format(no))\n\n\nif __name__ == '__main__':\n for i in range(0, 10):\n queuing.broker.send('m1', {\n 'no': i\n })\n\n queuing.broker.loop()\n\n```\n\n", "description_content_type": "text/markdown", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/vojtek/queuing", "keywords": "", "license": "MIT", "maintainer": "", "maintainer_email": "", "name": "queuing", "package_url": "https://pypi.org/project/queuing/", "platform": "", "project_url": "https://pypi.org/project/queuing/", "project_urls": { "Homepage": "https://github.com/vojtek/queuing" }, "release_url": "https://pypi.org/project/queuing/0.3.1/", "requires_dist": null, "requires_python": "", "summary": "Multithreating producent-consumer solution", "version": "0.3.1" }, "last_serial": 4716378, "releases": { "0.2.2": [ { "comment_text": "", "digests": { "md5": "1a13270dc00b9340de64541b8d6e40c2", "sha256": "75b58d9c3b61c7a547b3ca03fa6d39b1cb80e0501e760f5278cf4ec501de34d4" }, "downloads": -1, "filename": "queuing-0.2.2-py3-none-any.whl", "has_sig": false, "md5_digest": "1a13270dc00b9340de64541b8d6e40c2", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 2815, "upload_time": "2019-01-18T18:52:01", "url": "https://files.pythonhosted.org/packages/4e/1f/08323cb40caeee83f223a144be7ec483ba29c8a037d00bed891ab36c99f3/queuing-0.2.2-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "ee2ae14d55257c27eff038ab47325c4c", "sha256": "87e4dd340055b9dcc313757395be144cd420a9111877e8cd57dc8e958f610c85" }, "downloads": -1, "filename": "queuing-0.2.2.tar.gz", "has_sig": false, "md5_digest": "ee2ae14d55257c27eff038ab47325c4c", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 1557, "upload_time": "2019-01-18T18:52:03", "url": "https://files.pythonhosted.org/packages/45/83/f42a94c8a55741fe367349bd8686774bcc7bf847d3e76a0771ef734e6e40/queuing-0.2.2.tar.gz" } ], "0.3.0": [ { "comment_text": "", "digests": { "md5": "07185f75bf4e691ffb39501dc3b261fd", "sha256": "42c358e103711aa97099a2a8ea74e819e49bccd78a691b3169f5489b0fe81eb6" }, "downloads": -1, "filename": "queuing-0.3.0-py3-none-any.whl", "has_sig": false, "md5_digest": "07185f75bf4e691ffb39501dc3b261fd", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 3445, "upload_time": "2019-01-18T23:43:15", "url": "https://files.pythonhosted.org/packages/74/ae/71bb074f27e5d75dc8ba578291e952925203e41db4290993155289762eb4/queuing-0.3.0-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "744b974c6297c07820732fb9ca826ece", "sha256": "848a15fd07b61552dad56bcdf9eba4be765c9396b2f79819505d4bb13cb04785" }, "downloads": -1, "filename": "queuing-0.3.0.tar.gz", "has_sig": false, "md5_digest": "744b974c6297c07820732fb9ca826ece", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 2234, "upload_time": "2019-01-18T23:43:17", "url": "https://files.pythonhosted.org/packages/22/b9/5615f3c2d53f1cd4a9a9945430ea1161435befffea6fd1cb09a573ff1f75/queuing-0.3.0.tar.gz" } ], "0.3.1": [ { "comment_text": "", "digests": { "md5": "90ade6e0e7d1e29b50e489036444cf37", "sha256": "23cae7d63a7149857844f7c23556a4d63f28fe4566c72c5c0e6fe8cde2853b0c" }, "downloads": -1, "filename": "queuing-0.3.1-py3-none-any.whl", "has_sig": false, "md5_digest": "90ade6e0e7d1e29b50e489036444cf37", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 3397, "upload_time": "2019-01-19T19:36:04", "url": "https://files.pythonhosted.org/packages/6f/74/c28adce5334eb00347c061f670773f3c18d9f579dce72609c0515487b16d/queuing-0.3.1-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "07e158baf2caf85e1874fe3da60e9709", "sha256": "c2e846d8febcad5f507539f6efcc1c239e222c99c978943c06028fddb1d8c15e" }, "downloads": -1, "filename": "queuing-0.3.1.tar.gz", "has_sig": false, "md5_digest": "07e158baf2caf85e1874fe3da60e9709", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 2204, "upload_time": "2019-01-19T19:36:06", "url": "https://files.pythonhosted.org/packages/76/26/3a1d19f2165e45d90bfce9123dd9044d8893b2fba65abe29f0520c1d9866/queuing-0.3.1.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "90ade6e0e7d1e29b50e489036444cf37", "sha256": "23cae7d63a7149857844f7c23556a4d63f28fe4566c72c5c0e6fe8cde2853b0c" }, "downloads": -1, "filename": "queuing-0.3.1-py3-none-any.whl", "has_sig": false, "md5_digest": "90ade6e0e7d1e29b50e489036444cf37", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 3397, "upload_time": "2019-01-19T19:36:04", "url": "https://files.pythonhosted.org/packages/6f/74/c28adce5334eb00347c061f670773f3c18d9f579dce72609c0515487b16d/queuing-0.3.1-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "07e158baf2caf85e1874fe3da60e9709", "sha256": "c2e846d8febcad5f507539f6efcc1c239e222c99c978943c06028fddb1d8c15e" }, "downloads": -1, "filename": "queuing-0.3.1.tar.gz", "has_sig": false, "md5_digest": "07e158baf2caf85e1874fe3da60e9709", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 2204, "upload_time": "2019-01-19T19:36:06", "url": "https://files.pythonhosted.org/packages/76/26/3a1d19f2165e45d90bfce9123dd9044d8893b2fba65abe29f0520c1d9866/queuing-0.3.1.tar.gz" } ] }