Simulationssystem

Zielsetzung

Simulation in einem Netz mit 10E9 Punkten.

Dies setzt hohe Effizienz voraus, sowohl in Datenhaltung als auch in Programmperformance.

Höchste Effizienz ist nur bei Verarbeitung im Haupspeicher gewährleistet: Bei 100 Takten pro Transaktion (in einem Punkt), 50 Threads und 1 Milliarde Punkte und 2 GHz CPU-Takt ergibt das 1 Sekunde zur Verarbeitung dieser Transaktion über alle Punkte.

Systemaufbau

Es stehen eine Reihe von Grundelementen zur Verfügung, die hocheffizient Daten in den Punkten erzeugen (Modellierung) oder Daten aus den Punkten gewinnen (Aggregation).

Diese Elemente können in einer speziellen Sprache verwendet werden um die Simulation zu beschreiben.

Aus dieser Simulationsbeschreibung wird Quellcode erzeugt, der dann compiliert und abgearbeitet wird.

Aufteilung des Netzes bei zu großen Datenmengen

Passen die Daten aller Punkte nicht in den Arbeitsspeicher, so können die Punkte in Teilgebiete zerlegt werden, die dann in den Arbeitsspeicher passen:

Beispiel: Daten pro Punkt 1000 Byte, Punkte: 20000*50000 = 1E9, Arbietsspeicher 500 GByte: Aufteilung in 2 Paritionen mit 20000*25000 und 20000*25000

Beispiel für Simulation

Eine Simulation soll die Temperaturentwicklung bei Sonneneinstrahlung ermitteln. Gegeben sei ein Punkt-Oberflächentyp, der die Beschaffenheit der Oberfläche beschreibt, hier vereinfacht: Straße, Wald, Haus ("street", "wood", "house"). Die Temperaturerhöhung erfolgt in Abhängigkeit des Punkttyps, danach erfolgt ein Temperaturausgleich zwischen den Nachbarpunkten.

Da der Ausgleichsvorgang auf einer Kopie der Daten erfolgen muss (die Nachbarpunkte dürfen sich während der Berechnung nicht ändern!), wird das Modell in der Simulation in Teildaten (hier 1000x1000 Punkte) zerlegt und darauf die Berechnung ausgeführt. Danach werden die Daten wieder ins Gesamtmodell transferiert.

Am berechneten Gesamtmodell wird dann die Durchschnittstemperatur als Aggregation aller Punkte ermittelt.

# gegebenes Modell laden
model.load("Modell-01");
# Sicherstellen, dass jeder Punkt ein Attribut "Oberflächentyp" hat. Abbruch der Simulation, wenn nicht.
model.hasAttribute("surfacetype");
# Jeder Punkt bekommt ein Attribut "Temperatur" mit Datentyp Festpunktzahl 16 Bit mit 2 Dezimalstellen)
punkt.addAttribut("temperature", fixpoint(16,2));
# Alle Punkte auf 20 Grad setzen:
modell.setAll("temperature", 20.00);
# definieren einer Transaktion: die Funktion liefert abhängig vom Punktoberflächentyp eine Temperaturerhöhung:
define Temp(type, temp):
  switch(type)
  case 'street': temp + 10;
  case 'wood': temp + 2;
  case 'house': temp + 8;

# divideRectangle(): Aufteilung aller Punkte in 1000*1000 Punkte. 
# toModel(): Jedes Subquadrat wird als Model behandelt (damit stehen alle Funktionen des Models zur Verfügung).
# transaktion(): Für jeden Punkt des Submodells wird die Transaktion durchgeführt: Funktion Temp mit Attributen "surfacetype" und Attribut "temperature"
# neigbourLinearAdaption(): jeder Punkt im Model wird im Attribut "temperature" linear mit den Nachbarpunkten abgeglichen: die Temperatur
#  eines Punktes wird aus dem Durchschnitt aller Temperaturen der angrenzenden Punkte berechnet:
#  Gewichtung des Punktes: 2, Gewichtung von (4) Kantennachbarn: 1/4=0.25, Gewichtung von (4) Eckpunkten: 1/8=0.125
# intoModel(): Überführung der Daten des Submodels in das Gesamt-Model.
model.divideRectangle(1000, 1000)
  .toModel()
  .transaktion(Temp, "surfacetype", "temperature")
  .neigbourLinearAdaption("temperature", 2, 0.25, 0.125)
  .intoModel().;
#
# Durchschnittstemperatur des Gesamtpunktnetzes ermitteln:
model.aggregate("temperature", "Aufheizung der Luft bei Sonnenschein");
# Modell unter dem Namen "Modell-02" mit Kommentar speichern:
model.store("Modell-02", "Aufheizung der Luft");