前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Python中线程池的实现(三)

Python中线程池的实现(三)

原创
作者头像
用户7108768
修改2021-09-24 10:38:42
3990
修改2021-09-24 10:38:42
举报
代码语言:javascript
复制
# -- coding: utf-8 --
Java 理论与实践: 线程池与工作队列: http://www.ibm.com/developerworks/cn/java/j-jtp0730/
线程池原理及python实现: http://www.cnblogs.com/goodhacker/p/3359985.html
Threadpool: http://chrisarndt.de/projects/threadpool/
http://www.cnblogs.com/coser/archive/2012/03/10/2389264.html
import Queue
import threading
class ThreadPool(object):
    def init(self, maxsize=4, timeout=1):
        self._maxsize = maxsize
        self._timeout = timeout
        self._threads = []
        self._work_queue = Queue.Queue()
        self._create_threads()
    def execute(self, func, *args, **kwargs):
        self._work_queue.put((func, args, kwargs))

    # self._append_thread()
def dismiss(self, do_join=False):
    dismiss_list = []
    for i in range(len(self._threads)):
        thread = self._threads.pop()
        thread.dismiss()
        dismiss_list.append(thread)
    if do_join:
        for thread in dismiss_list:
            thread.join()
def _create_threads(self):
    for i in range(self._maxsize):
        self._threads.append(WorkThread(self._work_queue, self._timeout))
# def _append_thread(self):
#     num_thread = len(self._threads)
#     if num_thread == self._maxsize:
#         return
#     num_work = self._work_queue.qsize()
#     if num_thread >= num_work:
#         return
#     for i in range(num_thread, min(num_work, self._maxsize)):
#         self._threads.append(WorkThread(self._work_queue, self._timeout))

 
class WorkThread(threading.Thread):
    def init(self, work_queue, timeout=1):
        super(WorkThread, self).init()
        self._work_queue = work_queue
        self._timeout = timeout
        self._dismissed = threading.Event()
        self.start()
    def run(self):
        while True:
            if self._dismissed.isSet() \
                    and self._work_queue.qsize() == 0:
                break
            try:
                func, args, kwargs = self._work_queue.get(True, self._timeout)
            except Queue.Empty:
                continue
            else:
                func(*args, **kwargs)

    # print("%s exited!" % threading.current_thread())
def dismiss(self):
    self._dismissed.set()

 
if name == 'main':
    import time

def do_sth(n):
    time.sleep(0.1)
    print("task%s in %s" % (n, threading.current_thread()))

pool = ThreadPool()
for i in range(0, 20):
    pool.execute(do_sth, i)
pool.dismiss(True)

print("completed!")</pre> 

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
http://www.vxiaotou.com