Source code for ts_benchmark.utils.parallel.base

# -*- coding: utf-8 -*-

from __future__ import absolute_import

import abc
from typing import Any, NoReturn


[docs] class TaskResult(metaclass=abc.ABCMeta):
[docs] @abc.abstractmethod def result(self) -> Any: """ block until result is available """
[docs] @abc.abstractmethod def put(self, value: Any) -> NoReturn: """ set value of the result """
[docs] class SharedStorage(metaclass=abc.ABCMeta):
[docs] @abc.abstractmethod def put(self, name: str, value: Any) -> NoReturn: """ store variable into storage """
[docs] @abc.abstractmethod def get(self, name: str, default_value: Any = None) -> Any: """ get variable from storage """