Updated concurrency.
This commit is contained in:
parent
b730d1df6a
commit
08c8a07067
@ -14,7 +14,7 @@ class Downie(BaseApplication):
|
|||||||
|
|
||||||
def __init__(self, request_concurrency_limit=500,write_concurrency_limit=10,*args, **kwargs):
|
def __init__(self, request_concurrency_limit=500,write_concurrency_limit=10,*args, **kwargs):
|
||||||
self.base_url = None
|
self.base_url = None
|
||||||
self.request_concurrency_limit = 500
|
self.request_concurrency_limit = 10
|
||||||
self.write_concurrency_limit = 10
|
self.write_concurrency_limit = 10
|
||||||
self.semaphore_write = asyncio.Semaphore(self.write_concurrency_limit)
|
self.semaphore_write = asyncio.Semaphore(self.write_concurrency_limit)
|
||||||
self.semaphore_request = asyncio.Semaphore(self.request_concurrency_limit)
|
self.semaphore_request = asyncio.Semaphore(self.request_concurrency_limit)
|
||||||
|
Loading…
Reference in New Issue
Block a user