Wie Schreibe ich eine Folge von Versprechungen in Python?

Ist es möglich, zu schreiben, eine Folge von Versprechen (oder Aufgaben) mit nur Python 3.6.1 Standard-Bibliothek?

Beispielsweise eine Sequenz von zusagen in JavaScript geschrieben werden als:

const SLEEP_INTERVAL_IN_MILLISECONDS = 200;

const alpha = function alpha (number) {
    return new Promise(function (resolve, reject) {
        const fulfill = function() {
            return resolve(number + 1);
        };

        return setTimeout(fulfill, SLEEP_INTERVAL_IN_MILLISECONDS);
    });
};

const bravo = function bravo (number) {
    return new Promise(function (resolve, reject) {
        const fulfill = function() {
            return resolve(Math.ceil(1000*Math.random()) + number);
        };
        return setTimeout(fulfill, SLEEP_INTERVAL_IN_MILLISECONDS);
    });
};

const charlie = function charlie (number) {
    return new Promise(function (resolve, reject) {
        return (number%2 == 0) ? reject(number) : resolve(number);
    });
};

function run() {
    return Promise.resolve(42)
        .then(alpha)
        .then(bravo)
        .then(charlie)
        .then((number) => {
            console.log('success: ' + number)
        })
        .catch((error) => {
            console.log('error: ' + error);
        });
}

run();

Jede Funktion gibt auch ein Versprechen mit asynchronen Verarbeitung zur Folge, dass würde aufgelöst werden/abgelehnt werden, indem die unmittelbar folgenden Versprechen.

Ich bin mir bewusst, Bibliotheken wie verspricht-2.01 b und asyncio 3.4.3 und ich bin auf der Suche nach einem Python-STL-Lösung. Also, wenn ich für den import nicht-STL-Bibliothek, die ich lieber mit RxPython statt.

InformationsquelleAutor JP Ventura | 2017-04-10
  1. 17

    Hier ist ein ähnliches Programm mit asyncio und die async/await synthax:

    import asyncio
import random

async def alpha(x):
    await asyncio.sleep(0.2)
    return x + 1 

async def bravo(x):
    await asyncio.sleep(0.2)
    return random.randint(0, 1000) + x

async def charlie(x):
    if x % 2 == 0:
        return x
    raise ValueError(x, 'is odd')

async def run():
    try:
        number = await charlie(await bravo(await alpha(42)))
    except ValueError as exc:
        print('error:', exc.args[0])
    else:
        print('success:', number)

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(run())
    loop.close()

    EDIT: Wenn du daran interessiert bist reactive-streams, sollten Sie überlegen, mit aiostream.

    Hier ein einfaches Beispiel:

    import asyncio
from aiostream import stream, pipe

async def main():
    # This stream computes 11² + 13² in 1.5 second
    xs = (
        stream.count(interval=0.1)      # Count from zero every 0.1 s
        | pipe.skip(10)                 # Skip the first 10 numbers
        | pipe.take(5)                  # Take the following 5
        | pipe.filter(lambda x: x % 2)  # Keep odd numbers
        | pipe.map(lambda x: x ** 2)    # Square the results
        | pipe.accumulate()             # Add the numbers together
    )
    print('11² + 13² = ', await xs)

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())
    loop.close()

    Mehr Beispiele in der Dokumentation.

    • Cool! Die einzige schlechte Teil ist die Teleskop-Methode invocation. Wie in der Hoffnung, etwas zu schreiben, mehr wie eine JS-Versprechen Sequenz oder reaktive beobachten stream. Aber das man schon meine Probleme löst 🙂
    • Ja, diese Zeile ist ein bisschen lang, aber Sie können es aufgeteilt durch die Verwendung zusätzlicher Variablen. asyncio nicht mit einem pipe-syntax, da er versucht, möglichst nahe an der synchronen Programmierung wie möglich Auch, siehe mein edit über reactive streams.
    • könnten Sie bitte mal hier: stackoverflow.com/questions/53466252/...
    InformationsquelleAutor Vincent
  2. 4

    Haben Sie Glück, Python 3.4 und höher enthalten asyncio, obwohl die Funktion die du suchst (Zukunft) ist verfügbar in Python 3.5 und höher.

    Aus Ihrem eigenen link über asyncio: "Diese version ist nur relevant für Python 3.3, was keine asyncio in seiner stdlib."

    Beispiel:

    import asyncio


async def some_coroutine():
    await asyncio.sleep(1)
    return 'done'


def process_result(future):
    print('Task returned:', future.result())


loop = asyncio.get_event_loop()
task = loop.create_task(some_coroutine())
task.add_done_callback(process_result)
loop.run_until_complete()
    • Wie würden Sie übersetzen Sie die vorhergehenden JS-Beispiel in Python 3.5 mit Zukunft?
    InformationsquelleAutor Wolph
Schreibe einen Kommentar