ZFX + Developia

Code: Alles auswählen

std::vector<Dingens> mDingenses;
mDingenses.reserve(anzahl);
for( 0 .. anzahl )
  mDingenes.emplace_back(...Konstruktorparameter...);

Code: Alles auswählen

/// @file Traum_ParallelArbeiter.h
/// Ein Arbeiter, der anfallende Aufgaben in seinem eigenen Thread ausführt

#pragma once

/// Führt in dem Thread, in dem er gestartet wurde, Aufgaben aus der Warteschlange aus.
class Traum_ParallelArbeiter
{
  friend class Traum_Parallel;

public:
  /// Konstruktor, nimmt eine Warteschlange entgegen, aus der er Jobs ausführt, und die Wartebedingung, an der er lauscht,
  /// wenn's gerade nix zu tun gibt
  Traum_ParallelArbeiter( moodycamel::ConcurrentQueue<Traum_ParallelFaser*>& pWarteschlange, std::mutex& pMutex, 
    std::condition_variable& pBedingung);

private:
  /// Arbeitsfunktion, sollte im dafür vorgesehenen Thread aufgerufen werden.
  void Arbeiten();

  /// Sagt dem Arbeiter, dass er zum Ende kommen soll
  void SetEndeSignal();

private:
  /// die Warteschlange, aus der wir Aufgaben ziehen
  moodycamel::ConcurrentQueue<Traum_ParallelFaser*>& mWarteschlange;
  /// Mutex und Bedingung, auf denen wir warten, bis wieder was zu tun ist
  std::mutex& mMutex;
  std::condition_variable& mBedingung;

  /// besagt, ob wir zum Ende kommen sollen.
  std::atomic_bool mIstEndeGefordert;

  /// ordentliches Stück Platzhalterspeicher ans Ende, damit jeder Arbeiter in einer eigenen Cache-Zeile landet
  static const size_t PlatzhalterGroesse = 256 - 3*sizeof( void*) - sizeof( std::atomic_bool);
  uint8_t mPlatzhalter[PlatzhalterGroesse];
};