Мой текущий код
Код: Выделить всё
#!/usr/bin/env python3
# encoding: utf-8
"""Demonstration of Ray parallelism"""
import ray
from typing import Iterator
ray.init()
@ray.remote
def square(n:int)->int:
return n*n
references: Iterator[ray.ObjectRef] = map(lambda val: square.remote(val),
range(10))
ray.get([*references])
ray.shutdown()
Вопрос
Для такого стандартного и распространенного шаблона приведенная выше операция выглядит слишком многословной. Итак, предлагает ли Ray какой-либо API, предоставляющий более декларативный/функциональный интерфейс для получения вышеуказанного результата? В дополнение к карте лучше всего, если она предлагает какой-нибудь фильтр, уменьшение и т. д.
Подробнее здесь: https://stackoverflow.com/questions/785 ... unction-to