{ "info": { "author": "Lijiacai", "author_email": "1050518702@qq.com", "bugtrack_url": null, "classifiers": [], "description": "long_desciption\n from Producer_Consumer.QueueTool import QueueProducer\n\n from Producer_Consumer.QueueTool import QueueConsumer\n\n from Producer_Consumer.QueueTool import QueueConsumerProcess\n\n import multiprocessing\n\n import json\n\n \n\n \n\n def test_func(data):\n\n \"\"\"test function\"\"\"\n\n return json.dumps({\"result\": data})\n\n \n\n \n\n def test():\n\n \"\"\"test\"\"\"\n\n process_list = []\n\n producer = QueueProducer()\n\n lock = multiprocessing.Lock()\n\n for i in range(4):\n\n p = QueueConsumerProcess(target=test_func, input_queue=producer.queue, filename=\"123.json\",\n\n name=\"process%d\" % i, lock=lock)\n\n p.start()\n\n process_list.append(p)\n\n \n\n for i in range(1000000):\n\n producer.produce(str(i))\n\n \n\n print(\"produce done\")\n\n for p in process_list:\n\n p.stop()\n\n p.join()\n\n \n\n \n\n if __name__ == '__main__':\n\n test()", "description_content_type": "", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/lijiacaigit/Producer_Comsumer", "keywords": "Queue,queue,Producer_Consumer,producer_consumer,producer,consumer,process", "license": "MIT License", "maintainer": "", "maintainer_email": "", "name": "Producer-Consumer", "package_url": "https://pypi.org/project/Producer-Consumer/", "platform": "any", "project_url": "https://pypi.org/project/Producer-Consumer/", "project_urls": { "Homepage": "https://github.com/lijiacaigit/Producer_Comsumer" }, "release_url": "https://pypi.org/project/Producer-Consumer/19.9/", "requires_dist": null, "requires_python": "", "summary": "producer and consumer models", "version": "19.9" }, "last_serial": 5707153, "releases": { "19.6": [ { "comment_text": "", "digests": { "md5": "3359fc6cda50c847e442c618916f5cbe", "sha256": "ea330a2738b5fe7166b9d6df15867fea2235cacf1b777282ee69017d1c262a63" }, "downloads": -1, "filename": "Producer_Consumer-19.6.tar.gz", "has_sig": false, "md5_digest": "3359fc6cda50c847e442c618916f5cbe", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3496, "upload_time": "2019-02-03T07:37:23", "url": "https://files.pythonhosted.org/packages/57/80/0518878a76c6021036a00636b4d8c18f6bb491627f5a0f958fadaf4d1526/Producer_Consumer-19.6.tar.gz" } ], "19.7": [ { "comment_text": "", "digests": { "md5": "ee04d60b281f6d0780ef2969846ce559", "sha256": "dda6d6f69806192bc48f055813c23e2a1ae3fcffbc576989c2ee349df22e3ca3" }, "downloads": -1, "filename": "Producer_Consumer-19.7.tar.gz", "has_sig": false, "md5_digest": "ee04d60b281f6d0780ef2969846ce559", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3506, "upload_time": "2019-02-03T07:42:04", "url": "https://files.pythonhosted.org/packages/48/8a/5a113e2183dd80443908a7230e5d9d5973a9d400c211279248e34b3a1426/Producer_Consumer-19.7.tar.gz" } ], "19.8": [ { "comment_text": "", "digests": { "md5": "94a86846d13f8408223f5483cf1286f7", "sha256": "7b671f791bc92d78bca36769f4365654227d7b48f3a6af91a6615df69e0e6305" }, "downloads": -1, "filename": "Producer_Consumer-19.8.tar.gz", "has_sig": false, "md5_digest": "94a86846d13f8408223f5483cf1286f7", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3430, "upload_time": "2019-08-21T05:50:45", "url": "https://files.pythonhosted.org/packages/3c/2d/64343bbfd1cf153f8d44e269eaf4146b0c350ce3442d96732c942cec9692/Producer_Consumer-19.8.tar.gz" } ], "19.9": [ { "comment_text": "", "digests": { "md5": "ba603db1f1ca14d35981ffb3bd8b81d1", "sha256": "ebc19386197f1466a5cfc1626ae32a61e6c9c2cb43ce725561aebf5170aae683" }, "downloads": -1, "filename": "Producer_Consumer-19.9.tar.gz", "has_sig": false, "md5_digest": "ba603db1f1ca14d35981ffb3bd8b81d1", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3438, "upload_time": "2019-08-21T05:57:54", "url": "https://files.pythonhosted.org/packages/33/ff/8d76a0f671b1d454c65ea770f1607f3a3874d79d9bb5fb7224791342b1ef/Producer_Consumer-19.9.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "ba603db1f1ca14d35981ffb3bd8b81d1", "sha256": "ebc19386197f1466a5cfc1626ae32a61e6c9c2cb43ce725561aebf5170aae683" }, "downloads": -1, "filename": "Producer_Consumer-19.9.tar.gz", "has_sig": false, "md5_digest": "ba603db1f1ca14d35981ffb3bd8b81d1", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3438, "upload_time": "2019-08-21T05:57:54", "url": "https://files.pythonhosted.org/packages/33/ff/8d76a0f671b1d454c65ea770f1607f3a3874d79d9bb5fb7224791342b1ef/Producer_Consumer-19.9.tar.gz" } ] }