/usr/lib/python3/dist-packages/ginga/misc/Future.py is in python3-ginga 2.6.1-2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 | #
# Eric Jeschke (eric@naoj.org)
#
# Copyright (c) Eric R. Jeschke. All rights reserved.
# This is open-source software licensed under a BSD license.
# Please see the file LICENSE.txt for details.
#
import threading
from . import Callback
class TimeoutError(Exception):
pass
class Future(Callback.Callbacks):
def __init__(self, data=None, priority=0):
Callback.Callbacks.__init__(self)
self.evt = threading.Event()
self.res = None
# User can attach some arbitrary data if desired
self.data = data
self.priority = priority
self.enable_callback('resolved')
# for sorting in PriorityQueues
def __lt__(self, other):
return self.priority < other.priority
def get_data(self):
return self.data
# TODO: Could add some args type/value, return value validation here
def freeze(self, method, *args, **kwdargs):
self.method = method
self.args = args
self.kwdargs = kwdargs
def thaw(self, suppress_exception=True):
self.evt.clear()
if not suppress_exception:
res = self.method(*self.args, **self.kwdargs)
else:
try:
res = self.method(*self.args, **self.kwdargs)
except Exception as e:
res = e
self.resolve(res)
return res
def has_value(self):
return self.evt.isSet()
def resolve(self, value):
self.res = value
self.evt.set()
# TODO: need to change callbacks on some custom plugins first
#self.make_callback('resolved', value)
self.make_callback('resolved')
def get_value(self, block=True, timeout=None, suppress_exception=False):
if block:
self.evt.wait(timeout=timeout)
if not self.has_value():
raise TimeoutError("Timed out waiting for value!")
if isinstance(self.res, Exception) and (not suppress_exception):
raise self.res
return self.res
def wait(self, timeout=None):
self.evt.wait(timeout=timeout)
if not self.has_value():
raise TimeoutError("Timed out waiting for value!")
return self.res
# END
|