Threads Problem

[Wippi11223]

Hallo,
könnt ihr mir bitte auf die Sprünge helfen ich habe folgenden Code:

try (BittrexExchange bittrexExchange = new BittrexExchange("", "")) {
            bittrexExchange.onUpdateSummaryState(exchangeSummaryState -> {
                if (exchangeSummaryState.getDeltas().length > 0) {
                    Arrays.stream(exchangeSummaryState.getDeltas())
                            .filter(marketSummary -> marketSummary.getMarketName().equals("BTC-ETH")).forEach(marketSummary ->
                                    System.out.println(
                                    String.format("24 hour volume for market %s: %s %s %s %s %s %s",
                                    marketSummary.getMarketName(),
                                    marketSummary.getVolume().toString(),
                                    //sdateformat.format(marketSummary.getTimeStamp()),
                                    marketSummary.getTimeStamp(),
                                    marketSummary.getHigh(),
                                    marketSummary.getLow(),
                                    marketSummary.getLast(),
                                    marketSummary.getCreated()
                            ))
                            );
                }

ich möchte diesen Stream genau 1 Minute abwarten und nach einer Minute eine neue Klasse aufrufen - wie machen ich das am besten?

 

[Java xyrse123]

Um das Programm an der Stelle für eine Minute abwarten zulassen kannst du folgendendes schreiben :

try {
        Thread.sleep(60000);
        } catch (InterruptedExceptione) {
        e.printStackTrace();
    }

 

[mrBrown]

Bitte Code-Tags ([code=java]//dein Code[/code]) benutzen

 

[Wippi11223]

vielen Dank für deine Antwort - aber ich denke das löst mein Problem nicht

ich möchte exakt 1 Minute die Daten vom Stream auslesen und nach einer Minute eine Methode aufrufen -> when ich sleep gehe dann macht er ja gar nichts oder?

 

[mrBrown]

Du hast dort keinen InputStream, von dem du lesen kannst. Dein Code ist effektiv nur eine Iteration über ein Array, was innerhalb eines Listeners aufgerufen wird (was, soweit ich das sehe, nicht unter deiner Controller liegt).


Beschreib doch mal abstrakt, was du genau machen möchtest.

 

[Wippi11223]

ich bekomme über die Methode onUpdateStream aktuelle Marktdaten über eine Array herein - das heisst wenn das System einen aktuellen Wert hat dann bekomme ich diesen - ich möchte nun aber alle Werte über eine Minute aufsummieren und exakt nach einer Minute meine Berechnungen fortsetzen (also eine weitere Methode aufrufen) - und nach der nächsten Minute das gleiche wieder - das heißt ich möchte Daten zusammenfassen.

 

[Wippi11223]

das heißt aber wenn keine Daten kommen möchte ich aber auch mit Wert 0 weiterrechnen - das heißt die Methode onUpdateStream ist kein Trigger für mich - ich brauchen eine Art "Thread" der parallel läuft oder?

 

[mrBrown]

Da gibt es gefühlt 42 verschiedene Möglichkeiten...

Du könntest die Werte in einer Liste speichern, und über einen Timer diese minütlich aufsummieren und leeren

 

[Wippi11223]

ok vielen dank hab dies nun so gelöst - hätte noch eine weitere Frage - wie kann ich aus diesem Array.stream Daten in einer externen Variable speichern sodass ich diese später weiterverarbeiten kann?

hier noch ein Beispiel:

(

//
Arrays.stream(exchangeSummaryState.getDeltas()).forEach(marketSummary -> marketSummary.getLast().toString());

)
Ich würde gerne
(

//
marketSummary.getLast().toString()

)
in einer Variable speichern und zwar außerhalb des Arrays streams sodass ich dies dort weiterverarbeiten kann[/code]

 

[Robat]

Meinst du sowas?

List<String> list = Arrays.stream(exchangeSummaryState.getDeltas()).map(marketSummary-> marketSummary.getLast().toString()).collect(Collectors.toList());

 

[Wippi11223]

Vielen Dank!

Ist dies aber das selbe oder?

MarketSummary[] marketSummaryarray = exchangeSummaryState.getDeltas();
                    int i = 0;
                   

                    while (i < marketSummaryarray.length) {
                        String stream_price = "";

                        MarketSummary singlesummary = marketSummaryarray[i];
                        String name = singlesummary.getMarketName();
                        stream_time = singlesummary.getTimeStamp().toInstant().toEpochMilli();
                        i++;
                        System.out.println(name + stream_time);
                       
                    }

 

[Wippi11223]

Meinst du sowas?

List<String> list = Arrays.stream(exchangeSummaryState.getDeltas()).map(marketSummary-> marketSummary.getLast().toString()).collect(Collectors.toList());

ist diese Variante schneller und effizienter? oder sind die beiden gleich nur anderer Syntax?

 

[Robat]

Ob es das selbe ist kann ich nicht sagen, da ich nicht weiß wie die Implementierung von getLast() und toString() ist.
Du hast auf jeden Fall am Ende ein Array und bei mir ist es eine Liste

 

[mihe7]

List<String> list = Arrays.stream(exchangeSummaryState.getDeltas()).map(marketSummary-> marketSummary.getLast().toString()).collect(Collectors.toList());

entspricht in etwa

List<String> list = new ArrayList<>();
for (MarketSummary s : exchangeSummaryState.getDeltas()) {
    list.add(s.getLast().toString());
}

@Wippi11223 Was willst Du mit den "Werten" eigentlich anfangen?

 

[Wippi11223]

Vielen Dank!! super hat geholfen!
Das sind Market Daten ich möchte sich weiterverarbeiten für eine Berechnung. Dazu habe ich noch eine Frage:

Ich bekomme nun alle 5 Sekunden Daten in der List - ich möchte anschließend eine Berechnung starten - diese dauert aber sicherlich länger als 5 Sekunden wenn ich diese gleich nach der Datensammlung aufrufe z.B. eine weitere Methode kann es sein dass hier eine Backlog entsteht und ich nicht mit der Weiterverarbeitung nicht nachkomme - wie kann ich das lösen dass die Berechnung seperat läuft? Muss ich dafür einen Threat starten?

 

[mihe7]

Das sind Market Daten ich möchte sich weiterverarbeiten für eine Berechnung.

Ja, das hatte ich bereits aus Deinen älteren Posts herausgelesen. Meine Frage sollte auf zwei Punkte abzielen:

1. Du speicherst einerseits Strings in einer Liste, schreibst andererseits, Du möchtest mit diesen gespeicherten Werten weiterrechnen. Wenn ich rechnen will, wandle ich vorher nicht in einen String um.
2. Du schreibst auch, dass Du aggregieren willst. Lässt sich dies ggf. über ein reduce abbilden?

Zu Deiner Frage: verstehe ich es richtig, dass theoretisch etwa alle 5 Sekunden Dein Listener aufgerufen wird und der Listener in keinem separaten Thread läuft? Dann muss die Berechnung in einem separaten Thread erfolgen, sonst wird Dein I/O-Thread blockiert.