B -,c@s8dZddlmZmZmZmZddlZGdddeZdS)z future_mrcfile -------------- Module which exports the :class:`FutureMrcFile` class. Classes: :class:`FutureMrcFile`: An object which represents an MRC file being opened asynchronously. )absolute_importdivisionprint_functionunicode_literalsNc@sjeZdZdZdifddZddZddZd d Zd d Zd dZ dddZ dddZ ddZ ddZ dS) FutureMrcFilea%Object representing an MRC file being opened asynchronously. This API deliberately mimics a :class:`~concurrent.futures.Future` object from the :mod:`concurrent.futures` module in Python 3.2+ (which we do not use directly because this code still needs to run in Python 2.7). cCs0dg|_||_tj|j||d|_|jdS)aInitialise a new :class:`FutureMrcFile` object. This constructor starts a new thread which will invoke the callable given in ``open_function`` with the given arguments. Args: open_function: The callable to use to open the MRC file. (This will normally be :func:`mrcfile.open`, but could also be :class:`~mrcfile.mrcfile.MrcFile` or any of its subclasses.) args: A tuple of positional arguments to use when ``open_function`` is called. (Normally a 1-tuple containing the name of the file to open.) kwargs: A dictionary of keyword arguments to use when ``open_function`` is called. N)targetargskwargs)_result_holder_open_function threadingZThread_run_threadstart)selfZ open_functionr r rr5lib/python3.7/site-packages/mrcfile/future_mrcfile.py__init__ s  zFutureMrcFile.__init__c OsLy|j||}||jd<Wn,tk rF}z||jd<Wdd}~XYnXdS)zjCall the open function and store the result in the holder list. (For internal use only.) rN)r r Exception)rr r Zmrcexrrrr7s  zFutureMrcFile._runcCsdS)zReturn :data:`False`. (See :meth:`concurrent.futures.Future.cancel` for more details. This implementation does not allow jobs to be cancelled.) Fr)rrrrcancelBszFutureMrcFile.cancelcCsdS)zReturn :data:`False`. (See :meth:`concurrent.futures.Future.cancelled` for more details. This implementation does not allow jobs to be cancelled.) Fr)rrrr cancelledJszFutureMrcFile.cancelledcCs |jS)zReturn :data:`True` if the :class:`~mrcfile.mrcfile.MrcFile` is currently being opened. (See :meth:`concurrent.futures.Future.running` for more details.) )ris_alive)rrrrrunningRszFutureMrcFile.runningcCs | S)zReturn :data:`True` if the file opening has finished. (See :meth:`concurrent.futures.Future.done` for more details.) )r)rrrrdoneZszFutureMrcFile.doneNcCs"||}t|tr|n|SdS)aReturn the :class:`~mrcfile.mrcfile.MrcFile` that has been opened. (See :meth:`concurrent.futures.Future.result` for more details.) Args: timeout: Time to wait (in seconds) for the file opening to finish. If ``timeout`` is not specified or is :data:`None`, there is no limit to the wait time. Returns: An :class:`~mrcfile.mrcfile.MrcFile` object (or one of its subclasses). Raises: :exc:`RuntimeError`: If the operation has not finished within the time limit set by ``timeout``. (Note that the type of this exception will change in future if this class is replaced by :class:`concurrent.futures.Future`.) :exc:`Exception`: Any exception raised by the :class:`~mrcfile.mrcfile.MrcFile` opening operation will be re-raised here. N) _get_result isinstancer)rtimeoutresultrrrras  zFutureMrcFile.resultcCs ||}t|tr|SdSdS)a+Return the exception raised by the file opening operation. (See :meth:`concurrent.futures.Future.exception` for more details.) Args: timeout: Time to wait (in seconds) for the operation to finish. If ``timeout`` is not specified or is :data:`None`, there is no limit to the wait time. Returns: An :exc:`Exception`, if one was raised by the file opening operation, or :data:`None` if no exception was raised. Raises: :exc:`RuntimeError`: If the operation has not finished within the time limit set by ``timeout``. (Note that the type of this exception will change in future if this class is replaced by :class:`concurrent.futures.Future`.) N)rrr)rrrrrr exception~s  zFutureMrcFile.exceptioncCs*|jj|d|jr td|jdS)zjReturn the result or exception from the file opening operation. (For internal use only.) )rzTimed out waiting for resultr)rjoinr RuntimeErrorr )rrrrrrs zFutureMrcFile._get_resultcCstdS)znNot implemented. (See :meth:`concurrent.futures.Future.add_done_callback` for more details.) N)NotImplementedError)rfnrrradd_done_callbackszFutureMrcFile.add_done_callback)N)N)__name__ __module__ __qualname____doc__rrrrrrrrrr$rrrrrs    r) r(Z __future__rrrrr objectrrrrrs