iFdZddlmZmZmZmZddlZGddeZdS)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_literalsNcXeZdZdZdifdZdZdZdZdZdZ dd Z dd Z d Z d Z d S) 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). cdg|_||_tj|j|||_|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 threadingThread_run_threadstart)self open_functionr r s `/srv/www/vhosts/g4struct/public_html/venv/lib/python3.11/site-packages/mrcfile/future_mrcfile.py__init__zFutureMrcFile.__init__ sU $f+ 'ty-1/5777  cz |j|i|}||jd<dS#t$r}||jd<Yd}~dSd}~wwxYw)zjCall the open function and store the result in the holder list. (For internal use only.) rN)rr Exception)rr r mrcexs rrzFutureMrcFile._run7so  (%$%t6v66C%(D  " " " ( ( (%'D  " " " " " " " (s : 5:cdS)zReturn :data:`False`. (See :meth:`concurrent.futures.Future.cancel` for more details. This implementation does not allow jobs to be cancelled.) Fr rs rcancelzFutureMrcFile.cancelB urcdS)zReturn :data:`False`. (See :meth:`concurrent.futures.Future.cancelled` for more details. This implementation does not allow jobs to be cancelled.) Fr rs r cancelledzFutureMrcFile.cancelledJr!rc4|jS)zReturn :data:`True` if the :class:`~mrcfile.mrcfile.MrcFile` is currently being opened. (See :meth:`concurrent.futures.Future.running` for more details.) )ris_alivers rrunningzFutureMrcFile.runningRs |$$&&&rc,| S)zReturn :data:`True` if the file opening has finished. (See :meth:`concurrent.futures.Future.done` for more details.) )r&rs rdonezFutureMrcFile.doneZs <<>>!!rNc^||}t|tr||S)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.  _get_result isinstancerrtimeoutresults rr/zFutureMrcFile.resultas3.!!'** fi ( ( LMrc^||}t|tr|SdS)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`.) Nr*r-s r exceptionzFutureMrcFile.exception~s3(!!'** fi ( ( M4rc|j||jrtd|jdS)zjReturn the result or exception from the file opening operation. (For internal use only.) )r.zTimed out waiting for resultr)rjoinr% RuntimeErrorr)rr.s rr+zFutureMrcFile._get_resultsP '*** < " " ?=>> >"1%%rct)znNot implemented. (See :meth:`concurrent.futures.Future.add_done_callback` for more details.) )NotImplementedError)rfns radd_done_callbackzFutureMrcFile.add_done_callbacks "!r)N)__name__ __module__ __qualname____doc__rrr r#r&r(r/r1r+r8r rrrrs,.b. ( ( ('''""":4&&&"""""rr) r< __future__rrrrrobjectrr rrr?s  ************P"P"P"P"P"FP"P"P"P"P"r