pykka

    0熱度

    1回答

    在主演示here提供的示例中,Fab-toolbar看起來不錯。 但是,如果您嘗試在自己的例子中使用它,它會變得比它應該更高,可以看到here。 <div ng-controller="AppCtrl" class="fabToolbardemoBasicUsage" ng-app="MyApp"> <md-content class="md-padding"> <p>

    5熱度

    1回答

    我目前正在試用Actor-concurreny(在Python上),因爲我想了解更多。所以我選擇了pykka,但是當我測試的時候,它比多了一半,慢了作爲一個正常的功能。 該代碼只是看它是否工作;它並不意味着優雅。 :) 也許我做錯了什麼? from pykka.actor import ThreadingActor import numpy as np class Adder(Threadi

    3熱度

    2回答

    我有一些用Python編寫的分析代碼。目前我正在使用Storm來處理流。因爲Storm允許使用消息序列化來調用python代碼,所以我在Storm風格的螺栓中調用Java/Scala中的Python代碼。我發現Pykka這是actor模型的Python實現。我想知道是否有辦法從Akka actors中調用Python代碼?例如,是否有可能將來自Akka演員的消息傳遞給Pykka演員?

    0熱度

    1回答

    Pykka登錄到名爲pykka的記錄器。我想要所有的異常,調試消息打印到控制檯,尤其是當運行測試,啓動和停止在用Mamba寫的Pykka中的actor。 我該怎麼做?

    0熱度

    2回答

    public class gameMain implements Screen { final main game; SpriteBatch batch; Texture img; private Texture alexTexture; private Rectangle alex; private Texture cTex;

    0熱度

    1回答

    我使用pykka python庫。我想創建一個演員,然後測試創建的演員是否屬於正確的類。 class MyActor(ThreadingActor): # ... actor = MyActor.start().proxy() assert actor.__class__ == MyActor # check here? 這裏actor.__class__是pykka.act

    0熱度

    1回答

    我使用pika與rabbitmq進行通信。我消耗一個隊列,當收到消息時,我啓動一個pykka的演員來運行我的邏輯,有時候我的邏輯可能會使用pika連接發佈message.but我發現,這將花費5秒創造actor.Here通道是代碼: def on_conn_open(connection): connection.channel(lambda ch:ch.basic_consume(on

    4熱度

    1回答

    更新2015年8月:對於想要使用消息傳遞的人,我目前會推薦使用zeromq。可以用作pykka的補充或完全替代。 我該如何聆聽RabbitMQ隊列中的消息,然後將它們轉發給Pykka中的演員? 目前,當我嘗試這樣做時,我會發現奇怪的行爲,系統停下來停下來。 這裏是我有我的演員來實現: class EventListener(eventlet.EventletActor): def __i