the best threadpool pack.
Project description
You can implement thread pools by adding a single line of code without changing the order of any previous code.
import vthread
@vthread.pool(3) # just use this line to make pool, Create a threadpool with three threads
def crawl(i):
import time;time.sleep(1) # Simulation time consuming
print("crawl_url:",i)
urls = ["http://url1",
"http://url2",
"http://url3",
"http://url4"]
for u in urls:
crawl(u) # This function becomes a function that adds the original function to the thread pool.
It provides a method for grouping the thread pool
import vthread
pool_1 = vthread.pool(5,gqueue=1) # open a threadpool with 5 threads named 1
pool_2 = vthread.pool(2,gqueue=2) # open a threadpool with 2 threads named 2
@pool_1
def foolfunc1(num):
time.sleep(1)
print(f"foolstring1, test3 foolnumb1:{num}")
@pool_2
def foolfunc2(num):
time.sleep(1)
print(f"foolstring2, test3 foolnumb2:{num}")
@pool_2
def foolfunc3(num):
time.sleep(1)
print(f"foolstring3, test3 foolnumb3:{num}")
for i in range(10): foolfunc1(i)
for i in range(4): foolfunc2(i)
for i in range(2): foolfunc3(i)
# default gqueue is 0
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distributions
No source distribution files available for this release.See tutorial on generating distribution archives.