mirror of
https://github.com/kovidgoyal/calibre.git
synced 2025-06-23 15:30:45 -04:00
Remove unused code
This commit is contained in:
parent
d02a6ea36a
commit
40a12c31c1
@ -1,40 +0,0 @@
|
|||||||
__license__ = 'GPL v3'
|
|
||||||
__copyright__ = '2008, Kovid Goyal <kovid at kovidgoyal.net>'
|
|
||||||
|
|
||||||
|
|
||||||
'''
|
|
||||||
Define a threaded interface for working with devices.
|
|
||||||
'''
|
|
||||||
|
|
||||||
import threading, Queue
|
|
||||||
|
|
||||||
|
|
||||||
class DeviceManager(object):
|
|
||||||
|
|
||||||
def __init__(self):
|
|
||||||
self.devices = []
|
|
||||||
self.device_jobs = Queue(0)
|
|
||||||
|
|
||||||
|
|
||||||
class Job(object):
|
|
||||||
count = 0
|
|
||||||
|
|
||||||
def __init__(self, func, args):
|
|
||||||
self.completed = False
|
|
||||||
self.exception = None
|
|
||||||
|
|
||||||
|
|
||||||
class Worker(threading.Thread):
|
|
||||||
|
|
||||||
def __init__(self, jobs):
|
|
||||||
self.jobs = jobs
|
|
||||||
self.results = []
|
|
||||||
threading.Thread.__init__(self)
|
|
||||||
self.setDaemon(True)
|
|
||||||
|
|
||||||
def run(self):
|
|
||||||
'''Thread loops taking jobs from the queue as they become available'''
|
|
||||||
while True:
|
|
||||||
self.jobs.get(True, None)
|
|
||||||
# Do job
|
|
||||||
self.jobs.task_done()
|
|
Loading…
x
Reference in New Issue
Block a user