From 79d09d013bfa6f4a3e5aa386ca5dc2e206802d18 Mon Sep 17 00:00:00 2001 From: Noah Levitt Date: Tue, 8 Jan 2019 11:15:20 -0800 Subject: [PATCH] ThreadPoolExecutor no longer used it was part of the multi-threaded warc writer implementation --- warcprox/__init__.py | 13 +------------ 1 file changed, 1 insertion(+), 12 deletions(-) diff --git a/warcprox/__init__.py b/warcprox/__init__.py index 6a8e00e..e2c8df7 100644 --- a/warcprox/__init__.py +++ b/warcprox/__init__.py @@ -1,7 +1,7 @@ """ warcprox/__init__.py - warcprox package main file, contains some utility code -Copyright (C) 2013-2018 Internet Archive +Copyright (C) 2013-2019 Internet Archive This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License @@ -57,17 +57,6 @@ class Jsonner(json.JSONEncoder): else: return json.JSONEncoder.default(self, o) -class ThreadPoolExecutor(concurrent.futures.ThreadPoolExecutor): - ''' - `concurrent.futures.ThreadPoolExecutor` supporting a queue of limited size. - - If `max_queued` is set, calls to `submit()` will block if necessary until a - free slot is available. - ''' - def __init__(self, max_queued=None, *args, **kwargs): - super().__init__(*args, **kwargs) - self._work_queue = queue.Queue(maxsize=max_queued or 0) - # XXX linux-specific def gettid(): try: