Das deutsche Python-Forum

Code: Alles auswählen

#!/usr/bin/env python
import dataclasses

import pandas as pd



@dataclasses.dataclass
class State:
    volume: float = 0
    mass: float = 0
    stage: int = 0


def get_important_results(results):
    last_rows = results.tail(3)
    mass = last_rows.groupby("stage")["mass"].sum()
    volume = last_rows.groupby("stage")["volume"].sum()
    return mass, volume


def main():
    # In reality there are many more values, as shown here
    states = [State() for _ in range(3)]
    result = pd.DataFrame([dataclasses.asdict(states[0])])
    for value in range(10):
        for stage, state in enumerate(states, 1):
            # Placeholder for calculating
            state.stage = stage
            state.volume = 300 + value * stage
            state.mass = 200 + value * stage
            result = pd.concat(
                [result, pd.DataFrame([dataclasses.asdict(state)])], ignore_index=True
            )
    mass, volume = get_important_results(result)
    general_results = pd.DataFrame([{"something": 123}])
    print(mass)
    print(mass[2])


if __name__ == "__main__":
    main()

Code: Alles auswählen

class Results:
    def __init__(self):
        self.xy = []

    def __repr__(self):
        return f"Tadaa: {self.xy!r}"

def calculate(result, a, b):
    result.xy.append(a + b)


def main():
    values = [(1, 2), (3, 4), (5, 6)]
    results = [Results() for _ in values]
    for _ in range(10):
        for result, (a, b) in zip(results, values):
            calculate(result, a, b)
    for result in results:
        print(result)

if __name__ == '__main__':
    main()

Code: Alles auswählen

from threading import Thread

class Results:
    def __init__(self):
        self.xy = []

    def __repr__(self):
        return f"Tadaa: {self.xy!r}"

def calculate(result, a, b):
    result.xy.append(a + b)


def main():
    values = [(1, 2), (3, 4), (5, 6)]
    results = [Results() for _ in values]
    for _ in range(10):
        stages = [(result, a, b) for result, (a, b) in zip(results, values)]
        thread = Thread(target=calculate, args=stages[0])
        thread.start()
        thread.join()
        calculate(*stages[1])
        calculate(*stages[2])
    for result in results:
        print(result)

if __name__ == '__main__':
    main()