Threads

hunter_spike · Nov 4th 2023

Moin zusammen,

ich bastel gerade für die Regelung der Pufferspeicher meiner Stückholzheizung eine neue Steuerung zusammen:

Da das Einlesen von den DS18B20-Temperatursensoren rund 1 Sekunde pro Sensor benötigt, und ich im "Endstadium" rund 30 Sensoren haben werde, ist mir das ein bisschen lang. Ich muss Ventilmotoren zeitgenau anhalten, wenn sie einen Endschalter erreichen und ähnliches.

Darum hab ich mich mit Threads beschäftigt:

Die Raspberry Pi 3b hat vier Kerne. Ich kann also maximal 4 Threads gleichzeitig laufen lassen hab ich gelesen. Allerdings frage ich mich da, wo der Rest der Raspi (LXDE etc...) verarbeitet wird.

Kann ich eine Funktion gleichzeitig aus verschiedenen Threads aufrufen?

Zählt "this_thread" auch als thread? müsste ich den also bei die maximal 4 Threads beirechnen?

Danke euch,

Achim

Bot · Vor 5 Minuten

Schau mal ob du hier fündig wirst!

Bernd666 · Nov 5th 2023

Moin hunter_spike,

du kannst einen Thread nicht einem bestimmten Kern zuordnen. Das Zuteilen sollte besser das Betriebssystem machen.

Das Auslesen von 30 Sensoren in Threads aufzuteilen macht eigentlich keinen Sinn. Weil das Auslesen der Sensoren dauert auch da 1 Sekunde. Was macht denn deine Mainschleife in der Zeit??

Kannst du mal schreiben in welcher Programmiersprache du das machen willst.

Auch kann ich mir nicht vorstellen, das alle 30 Sensoren so wichtig sind.

Man kann die Auslesezeit erheblich verkürzen wenn man nicht auf 12bit Genauigkeit besteht.

Dann hat der Sensor eine Alarmfunktion. Die könnte man einsetzen um wichtige Temperaturwerte zu überwachen.

Nu so meine Gedanken...

73 de Bernd

hunter_spike · Nov 5th 2023

Hallo Bernd,

ich hab mich wohl zum Teil nicht richtig ausgedrückt.

Ein Thread soll ganz gemütlich, alle 30 Sekunden, die Sensoren einlesen und die Werte ans Hauptprogramm übergeben.

Ein anderer Thread schaltet einen Motor ein und wartet gespannt darauf, das der passende Endschalter kommt und er den Motor sofort ausschaltet.

Sprache ist C++ .... wie dieses Forum....

Bot · Vor einem Moment

RTFM · Nov 5th 2023

Quote from hunter_spike

Da das Einlesen von den DS18B20-Temperatursensoren rund 1 Sekunde pro Sensor benötigt, und ich im "Endstadium" rund 30 Sensoren haben werde,

Da bist Du aber selber schuld, wenn Du die Sensoren im voreingestellten 12-Bit Modus verwendest. Siehe Datenblatt.

Servus !

Tell · Nov 5th 2023

Bevor du ueber die Threadas nachdenkst solltest du verifizieren dass der Treiber fuer den DS18B20 ueberhaupt mehrere Threads gleichzeitig bedienen kann. Wenn der Treiber die Abfragen serialisiert hast du einfach eine Warteschlange vor dem Treiber...

> Kann ich eine Funktion gleichzeitig aus verschiedenen Threads aufrufen?
Kommt drauf an ob die Funktion reentrant ist.

hunter_spike · Nov 5th 2023

OK.

Um die 12 Bit hab ich mir keine Gedanken gemacht.

Kurz gegoogelt würde ich dann grob 3 Sekunden statt 30 Sekunden für die Sensoren benötigen.

Das werde ich später nochmal umstellen müssen, aber auch die 3 Sekunden sind zu lange, um die Endschalter der Motoren abzufragen. Somit muss ich mit Threads arbeiten, damit die Motorensteuerung parallel zur Datenerfassung läuft.

Bot · Vor einem Moment

hunter_spike · Nov 5th 2023

Quote from Tell

Bevor du ueber die Threadas nachdenkst solltest du verifizieren dass der Treiber fuer den DS18B20 ueberhaupt mehrere Threads gleichzeitig bedienen kann. Wenn der Treiber die Abfragen serialisiert hast du einfach eine Warteschlange vor dem Treiber...

> Kann ich eine Funktion gleichzeitig aus verschiedenen Threads aufrufen?
Kommt drauf an ob die Funktion reentrant ist.

ich lese die Temperatursensoren nacheinander mit ifstream aus dem Verzeichnis "/sys/bus/w1/devices/"Sensornummer"/temperarure" aus.

(wenn mir einer kurz erklärt wie ich eine Datei mit dem VNC-Viewer runter laden kann, könnte ich das Programm posten)

__blackjack__ · Nov 5th 2023

Wenn das verschiedene Geräte hinter den Dateinamen sind, dann liesse sich das schon parallelisieren, aber ich würde da eher mit ``select`` arbeiten als mit Threads. Wobei ich jetzt nicht weiss welche API man da unter C++ am besten nimmt. Denn die Frage nach der Programmiersprache machte schon Sinn, denn das Forum schränkt ja nur auf C oder C++ ein, aber nicht welche von beiden.

Threads könnten weiterhin Sinn machen um Auslesen und Steuerung zu trennen falls das Auslesen sonst zu lange die Steueraufgaben blockieren würde.

Zur Anzahl von Threads noch mal: Das System kann am Ende genau so viele Threads laufen lassen wie es gleichzeitig Prozesse laufen lassen kann, denn aus Sicht des Kernels sind Threads und Prozesse fast gleich. Der Hauptunterschied ist ob es getrennte Adressräume gibt oder nicht. Der Kernel entscheidet welche Threads (ein Prozess ist ja im Grunde auch ein einzelner Thread) auf welchem Kern für eine kurze Zeit ausgeführt wird, bevor dann nach einer (für Menschen sehr kurzen) Zeit wieder andere mal dran kommen und ein bisschen Prozessorzeit nutzen dürfen.

peuler · Nov 5th 2023

Zu der Frage nach der maximalen Anzahl von Threads hilft vielleicht das Programm tell_max_threads.cpp weiter. Eine kleine Doku ist hier zu finden.

Auf einem Raspberry Pi 2 bin ich auf über 200 Threads gekommen. An der Anzahl der Threads wird das Vorhaben wohl kaum scheitern.

Bot · Vor einem Moment

hunter_spike · Nov 5th 2023

Quote from peuler

.....
Auf einem Raspberry Pi 2 bin ich auf über 200 Threads gekommen. An der Anzahl der Threads wird das Vorhaben wohl kaum scheitern.

Ups

Man soll eben nicht alles glauben, was man im Netz liest.

Hatte mehrmals gelesen das die Anzahl der Kerne die Threads bestimmt.

hunter_spike · Nov 5th 2023

C

/*
In boot/config.txt eintragen:

#dtoverlay=w1-gpio,<param>=<val>
#1-wire aktivieren
dtoverlay=w1-gpio,gpiopin=4,pullup=0  # header pin 7
dtoverlay=w1-gpio,gpiopin=14,pullup=0 # header pin 15
dtoverlay=w1-gpio,gpiopin=15,pullup=0 # header pin 16

Für Autostart in /etc/rc.local eintragen:
/home/pi/Documents/c++/heiz/bin/Debug/./heiz

*/


#include <iostream>
#include <fstream>
#include <string>
#include <sstream>
#include <wiringPi.h>
#include <unistd.h>
#include <thread>

#define DOV1 0//Digital OUT Ventil 1
#define DOV2 1
#define DOV3 2
#define DOPumpHW 3 //Digital Out Pumpe Heisswasser
#define DOPumpWT 4 // ...Wärmetauscher
#define DOPumpHK 5 // ...HeizKreis
#define DOPumpZirk 12 // Zirkulation

#define DIV1S1 21 // Digital Input Ventil 1 Schalter 1
#define DIV1S2 22
#define DIV2S1 24
#define DIV2S2 27
#define DIV3S1 25
#define DIV3S2 28


using namespace std;

string Pfad[11] = { "/sys/bus/w1/devices/28-3cece381f7e5/temperature",//0
                    "/sys/bus/w1/devices/28-3cb0e3810f73/temperature",//1
                    "/sys/bus/w1/devices/28-3ca2e381aae7/temperature",//2
                    "/sys/bus/w1/devices/28-3cb3e38126f8/temperature",//3
                    "/sys/bus/w1/devices/28-3c97e3813e8e/temperature",//4
                    "/sys/bus/w1/devices/28-3cdee381bb11/temperature",//5
                    "/sys/bus/w1/devices/28-3c66e3815cb6/temperature",//6
                    "/sys/bus/w1/devices/28-3c70e3818de4/temperature",//7
                    "/sys/bus/w1/devices/28-3ce7e381cb88/temperature",//8  WWoben
                    "/sys/bus/w1/devices/28-3cd1e381ccae/temperature",//9  WWunten
                    "/sys/bus/w1/devices/28-3c60e381ad24/temperature"//10  WWrücklauf

                    };
float Temp[11];
bool WWLaden100;
bool WWLaden50;
bool PufferLaden50;
bool V1;
bool V2;
bool V3;


int Ventil1;
int Ventil2;
int Ventil3;

int V1S1;
int V1S2;
int V2S1;
int V2S2;
int V3S1;
int V3S2;



//pinMode(aus1, OUTPUT);


void Einlesen()
{
while(1){
    for(int i=0; i<= 10; i++){
    ifstream Tempsensor (Pfad[i]);
    Tempsensor >> Temp[i];

    cout << "Temp " << i <<": "<<(Temp[i] / 1000) << endl;
    }
//    V1S1 = digitalRead(DIV1S1);
//    V1S2 = digitalRead(DIV1S2);
//    V2S1 = digitalRead(DIV2S1);
//    V2S2 = digitalRead(DIV2S2);
//    V3S1 = digitalRead(DIV3S1);
//    V3S2 = digitalRead(DIV3S2);
}
}

void Ausgange()
{while(1){
    if((WWLaden100 == 0) && (WWLaden50 == 0) && (PufferLaden50 == 0)){
        Ventil1 = 1;
        }

    if(WWLaden100 == 1){
        Ventil1 = 3;  //1 = Mitte-links, 2 = Mitte - Rechts, 3 = Links - Rechts
        Ventil2 = 2;
        Ventil3 = 2;
        }

    if(WWLaden50 == 1){
        Ventil1 = 2;
        Ventil2 = 2;
        Ventil3 = 2;
        }

    if(PufferLaden50 == 1){
        Ventil1 = 2;
        Ventil2 = 1;
        Ventil3 = 1;
        }


    if(((Ventil1 == 1) && (V1S1 == 1)) || ((Ventil1 == 1) && (V1S2 == 1))){V1 = 1;}else{V1 = 0;}
    digitalWrite(DOV1, V1);

    if(((Ventil1 == 2) && (V1S1 == 0)) || ((Ventil1 == 2) && (V1S2 == 1))){V1 = 1;}else{V1 = 0;}
    digitalWrite(DOV2, V1);
    cout << "Ventil 1 Vorwahl     = " << Ventil1 << endl;
    cout << "Ventil 1 Ansteuerung = " << V1 << endl;
    cout << "V1S1     = " << V1S1 << endl;
    cout << "V1S2     = " << V1S2 << endl;

    sleep(1);
/*    while(1){
    digitalWrite(DOV1, 1);
    sleep(1);
    digitalWrite(DOV1, 0);
    sleep(1);
    }
*/
}
}
void Ablauf()
{while(1){
    if(Temp[0] > Temp[8]){WWLaden100 = 1;}else{WWLaden100 = 0;}
    if((Temp[0] > Temp[9]) && (WWLaden100 == 0)){WWLaden50 = 1;}else{WWLaden50 = 0;}

    cout << "WWLaden100    = " << WWLaden100 << endl;
    cout << "WWLaden50     = " << WWLaden50 << endl;
    cout << "PufferLaden50 = " << PufferLaden50 << endl;
sleep(1);
}
}void setup(){
        wiringPiSetup();

        pinMode(DOV1, OUTPUT);
        digitalWrite(DOV1, 1);
        pinMode(DOV2, OUTPUT);
        digitalWrite(DOV2, 1);
        pinMode(DOV3, OUTPUT);
        digitalWrite(DOV3, 1);
        pinMode(DOPumpHW, OUTPUT);
        digitalWrite(DOPumpHW, 1);
        pinMode(DOPumpWT, OUTPUT);
        digitalWrite(DOPumpWT, 1);
        pinMode(DOPumpHK, OUTPUT);
        digitalWrite(DOPumpHK, 1);
        pinMode(DOPumpZirk, OUTPUT);
        digitalWrite(DOPumpZirk, 1);

        pinMode(DIV1S1, INPUT);
        pullUpDnControl(DIV1S1, PUD_DOWN);
        pinMode(DIV1S2, INPUT);
        pullUpDnControl(DIV1S2, PUD_DOWN);
        pinMode(DIV2S1, INPUT);
        pullUpDnControl(DIV2S1, PUD_DOWN);
        pinMode(DIV2S2, INPUT);
        pullUpDnControl(DIV2S2, PUD_DOWN);
        pinMode(DIV3S1, INPUT);
        pullUpDnControl(DIV3S1, PUD_DOWN);
        pinMode(DIV3S2, INPUT);
        pullUpDnControl(DIV3S2, PUD_DOWN);
        }

void ventil(){
        V1 =1;
        digitalWrite(DOV1, 0);
        //digitalWrite(DOV2, 1);
        while(1){
        V1S1 = digitalRead(DIV1S1);
        V1S2 = digitalRead(DIV1S2);
        V2S1 = digitalRead(DIV2S1);
        V2S2 = digitalRead(DIV2S2);
        V3S1 = digitalRead(DIV3S1);
        V3S2 = digitalRead(DIV3S2);
        if(V1S1==1||V1S2==1){digitalWrite(DOV1, 0);}
        cout << V1 << "  " << V1S1 << "  " << V1S2 << endl;
        cout << V2 << "  " << V2S1 << "  " << V2S2 << endl;
        cout << V3 << "  " << V3S1 << "  " << V3S1 << endl;
        sleep(0.5);
        }
        }

int main(){
setup();
thread t1(Einlesen);
//thread t2(Ablauf);
//thread t3(Ausgange);

thread t4(ventil);

t1.join();
//t2.join();
//t3.join();
t4.join();

    //ausgange();

return 0;
}
;

Display More

Das Programm ist noch im Versuchsstadium. Darum ein paar Sachen auskommentiert, vielleicht was doppelt, und bestimmt Fehler drin...

DistroEx · Nov 5th 2023

Quote from hunter_spike

(wenn mir einer kurz erklärt wie ich eine Datei mit dem VNC-Viewer runter laden kann, könnte ich das Programm posten)

Rechtsklick auf das RealVNC-Symbol in der Taskleiste, dann auf "File Transfer..." (auf Deutsch vermutlich Dateiübertragung oder ähnlich).

Edit: und wieder zu spät...

Bot · Vor einem Moment

hunter_spike · Nov 5th 2023

Quote from DistroEx

Rechtsklick auf das RealVNC-Symbol in der Taskleiste, dann auf "File Transfer..." (auf Deutsch vermutlich Dateiübertragung oder ähnlich).

Edit: und wieder zu spät...

Trotzdem Danke!

Wenn dabei gestanden hätte, das das Kontextmenü mit der rechten Maustaste geht, hätte ich nicht so dumm fragen brauchen....

peuler · Nov 5th 2023

Zum Beitrag # 11:

Der Quelltext hat aus meiner Sicht mindestens 1 Designfehler:

Die Funktionen laufen alle in einer Endlosschleife: while(1) kommt nie zu einem Ende. Das hat zur Konsequenz, dass bei einem Abbruch des Threads dieser in einem undefiniertem Zustand endet. Besser wäre es, eine Bedingung zu definieren, die die Funktion ordentlich beenden lässt (die im Thread ausgeführt wird) und damit auch den Thread ordnungsgemäß zu einem Ende kommen lässt. Ich frage mich, wie die join-Aufrufe funktionieren sollen, weil die in den Threads aufgerufenen Funktionen nicht enden.

Ich bin kein Freund von Definitionen von namespaces. Meine bescheidene Erfahrung mit C++ hat ergeben, dass man besser versteht, was man tut, wenn man darauf verzichtet.

Noexpand · Nov 7th 2023

Quote from hunter_spike

Ups
Man soll eben nicht alles glauben, was man im Netz liest.
Hatte mehrmals gelesen das die Anzahl der Kerne die Threads bestimmt.

Jein.

Die Anzahl der Kerne bestimmt die Zahl der Threads, die gleichzeitig verarbeitet werden können. Generell ist es aber nicht unüblich, deutlich mehr Threads einzusetzen, als der Prozessor Kerne hat. Das kannst du auch selbst gut sehen, wenn du auf deinen Raspi einmal "ps -aux" aufrufst. All diese aufgelisteten Prozesse bestehen jeweils aus mindestens einem Thread.

In der Regel (so auch bei dir, siehe das sleep(1)) wartet ein einzelner Thread nämlich ständig auf irgendwelche Dinge¹ und in der Zeit könnte ein anderer Thread eben schnell auf dem Prozessor was rechnen.

¹ Das können die unterschiedlichsten Sachen sein:

Daten von der Netzwerkschnittstelle empfangen oder senden
Daten von der Festplatte lesen oder schreiben
Daten aus dem Hauptspeicher lesen oder schreiben
Auf ein bestimmtes Ereignis warten (Tastendruck, Mausbewegung, Bereitstellung eines Messwertes, Eintritt einer bestimmten Uhrzeit, Ablauf einer bestimmten Wartezeit)

Bot · Vor einem Moment

hunter_spike · Nov 10th 2023

Ich steh mal wieder auf dem Schlauch...

Kann mir jemand sagen warum das unten stehende Programm funktioniert???

Ich hab mit Sternchen markiert, wo meine Endschalter eingelesen werden und in eine Variable geschrieben werden.

Darunter wird die Variable "Ventil1ist" anhand der Endschalter bestimmt.

Rund 10 Zeilen weiter unten ist eine do-while-Schleife, in der ich nach meiner Auffassung so lange festhänge, bis "ist" und "soll" gleich sind.

Demnach dürften sich aber meine Eingangs-Variablen nicht mehr ändern, da ich die ja weiter oben beschreibe.

Warum funktioniert das Programm trotzdem?

Wenn ich "Ventil1soll" eine Zahl zwischen 1-3 gebe, dann fährt mein Motor ordentlich bis auf die gewünschten Nocken und bleibt da stehen.

Um es übersichtlicher zu machen habe ich ganz viel rausgekürzt.

Wenns hilft poste ich auch alle 250 Zeilen....

Code

#define DIV1S1 21
#define DIV1S2 22
#define DIV2S1 24
#define DIV2S2 27
#define DIV3S1 25
#define DIV3S2 28

bool v1;

int Ventil1soll;

int Ventil1ist;//Hat einen Wert 1,2 oder 3, je nach schalterstellung

int V1S1;
int V1S2;
int V2S1;
int V2S2;
int V3S1;
int V3S2;

void Einlesen()
{
while(1){
    for(int i=0; i<= 10; i++){
    ifstream Tempsensor (Pfad[i]);
    Tempsensor >> Temp[i];

    cout << "Temp " << i <<": "<<(Temp[i] / 1000) << endl;
    }
}

void V1(bool v1){
    digitalWrite(DOV1, !v1);}//Negierung, das die Relaiskarte negiert

void ventil(){
    Ventil1soll =1;//Manuelle Vorgabe zum Testen

    while(1){
    V1S1 = digitalRead(DIV1S1);// ********** Hier werden die Schalter eingelesen
    V1S2 = digitalRead(DIV1S2);// ********************************************************

    if(V1S1 == 0 && V1S2 == 1){Ventil1ist = 1;}//**************************
    if(V1S1 == 0 && V1S2 == 0){Ventil1ist = 2;}// Hier wird die IST-Position des Ventils bestimmt
    if(V1S1 == 1 && V1S2 == 0){Ventil1ist = 3;}
   
    cout <<"Ventil1Soll="<<Ventil1soll <<" Ventil1ist  =" << Ventil1ist << V1S1 << V1S2 << endl;
    usleep(100000);
    if(Ventil1soll != Ventil1ist){
        switch(Ventil1soll){
            case 1:
                V1(1);//Motor einschalten 
**********      do{ cout << "case1 Ventil1Soll=" <<Ventil1soll<<"Ventil1ist="<<Ventil1ist << endl;
                    usleep(500000);
                    if(V1S1==0){usleep(100000);}
                    if(V1S1==0 && V1S2==1){
                        V1(0);
                        break;
                        }
                    }
**************   while(Ventil1soll == Ventil1ist);
                V1(0);
                cout << "V1=0 case 1 end"<< endl;
                break;
            case 2:
                V1(1);
                do{ cout << "case2 Ventil1Soll  =" <<Ventil1soll <<"   Ventil1ist  =" << Ventil1ist << endl;
                    usleep(500000);
                    if(V1S1==0){usleep(100000);}
                    if(V1S1==0 && V1S2==0){
                        V1(0);
                        break;
                        }
                    }
                while(Ventil1soll == Ventil1ist);
                V1(0);
                cout << "V1=0 case 2 end"<< endl;
                break;
            case 3:
                V1(1);
                do{ cout << "case3 Ventil1Soll  =" <<Ventil1soll <<"   Ventil1ist  =" << Ventil1ist << endl;
                    usleep(500000);
                    if(V1S2==0){usleep(100000);}
                    if(V1S1==1 && V1S2==0){
                        V1(0);
                        break;
                        }
                    }
                while(Ventil1soll == Ventil1ist);
                V1(0);
                cout << "V1=0 case 3 end"<< endl;
                break;
        }
        }
        }


        if(V1S1==1||V1S2==1){V1(0);}
        V1(0);
        cout << "V1  " << V1 << "  " << V1S1 << "  " << V1S2 << endl;
        cout << "V2  " << V2 << "  " << V2S1 << "  " << V2S2 << endl;
        cout << "V3  " << V3 << "  " << V3S1 << "  " << V3S1 << endl;
        usleep(100000);
        }


int main(){
    setup();

    thread t1(Einlesen);
    //thread t2(Ablauf);
    //thread t3(Ausgange);

    thread t4(ventil);

    t1.join();
    //t2.join();
    //t3.join();
    t4.join();

    //ausgange();

return 0;
}
;

Display More

hunter_spike · Nov 10th 2023

Ich glaube, ich hab es selber gefunden....

Ganz unten in "main" rufe ich ja "thread t1(Einlesen)" und "thread t4(Ventile)" auf.

Kann es sein, das ich ganz viele "Einlesen" und "Ventile"-Funktionen am laufen habe???

__blackjack__ · Nov 10th 2023

Wieso ganz viele? Jeweils eine. Und der Hauptthread macht die ganze Zeit nichts als auf die beiden zu warten.

Bot · Vor einem Moment

peuler · Nov 10th 2023

Bitte stets den gesamten Quelltext und auch den Compiler-Aufruf posten. Mit gekürzten Versionen mag ich mich nicht beschäftigen.

hunter_spike · Nov 12th 2023

Hier das komplette Programm:

C

/*
In boot/config.txt eintragen:

#dtoverlay=w1-gpio,<param>=<val>
#1-wire aktivieren
dtoverlay=w1-gpio,gpiopin=4,pullup=0  # header pin 7
dtoverlay=w1-gpio,gpiopin=14,pullup=0 # header pin 15
dtoverlay=w1-gpio,gpiopin=15,pullup=0 # header pin 16

Für Autostart in /etc/rc.local eintragen:
/home/pi/Documents/c++/heiz/bin/Debug/./heiz

*/


#include <iostream>
#include <fstream>
#include <string>
#include <sstream>
#include <wiringPi.h>
#include <unistd.h>
#include <thread>
#include <time.h>

#define DOV1 0//Digital OUT Ventil 1 WiringPi-Ausgang 0
#define DOV2 1
#define DOV3 2
#define DOPumpHW 3
#define DOPumpWT 4
#define DOPumpHK 5
#define DOPumpZirk 12

#define DIV1S1 21// Digital Input Ventil 1, Schalter 1, WiringPi-Eingang 21
#define DIV1S2 22
#define DIV2S1 24
#define DIV2S2 27
#define DIV3S1 25
#define DIV3S2 28


using namespace std;

string Pfad[11] = {  "/sys/bus/w1/devices/28-3cece381f7e5/temperature",//0
                    "/sys/bus/w1/devices/28-3cb0e3810f73/temperature",//1
                    "/sys/bus/w1/devices/28-3ca2e381aae7/temperature",//2
                    "/sys/bus/w1/devices/28-3cb3e38126f8/temperature",//3
                    "/sys/bus/w1/devices/28-3c97e3813e8e/temperature",//4
                    "/sys/bus/w1/devices/28-3cdee381bb11/temperature",//5
                    "/sys/bus/w1/devices/28-3c66e3815cb6/temperature",//6
                    "/sys/bus/w1/devices/28-3c70e3818de4/temperature",//7
                    "/sys/bus/w1/devices/28-3ce7e381cb88/temperature",//8  WWoben
                    "/sys/bus/w1/devices/28-3cd1e381ccae/temperature",//9  WWunten
                    "/sys/bus/w1/devices/28-3c60e381ad24/temperature"//10  WWrücklauf

                    };
float Temp[11];
bool WWLaden100;
bool WWLaden50;
bool PufferLaden50;


bool v1;
bool v2;
bool v3;

int Ventil1soll;
int Ventil2soll;
int Ventil3soll;

int Ventil1ist;
int Ventil2ist;
int Ventil3ist;

bool V1S1;
bool V1S2;
bool V2S1;
bool V2S2;
bool V3S1;
bool V3S2;

int Stoerung;


void Einlesen()
{
while(1){
    for(int i=0; i<= 10; i++){
    ifstream Tempsensor (Pfad[i]);
    Tempsensor >> Temp[i];

    cout << "Temp " << i <<": "<<(Temp[i] / 1000) << endl;
    }
//    V1S1 = digitalRead(DIV1S1);
//    V1S2 = digitalRead(DIV1S2);
//    V2S1 = digitalRead(DIV2S1);
//    V2S2 = digitalRead(DIV2S2);
//    V3S1 = digitalRead(DIV3S1);
//    V3S2 = digitalRead(DIV3S2);
}
}

void V1(bool v1){
    digitalWrite(DOV1, !v1);}//Negiert, weil Relaiskarte negiert

void V2(bool v2){
    digitalWrite(DOV1, !v2);}

void V3(bool v3){
    digitalWrite(DOV1, !v3);}

void Ablauf()
    {while(1){
    if(Temp[0] > Temp[8]){WWLaden100 = 1;}else{WWLaden100 = 0;}
    if((Temp[0] > Temp[9]) && (WWLaden100 == 0)){WWLaden50 = 1;}else{WWLaden50 = 0;}

    cout << "WWLaden100    = " << WWLaden100 << endl;
    cout << "WWLaden50     = " << WWLaden50 << endl;
    cout << "PufferLaden50 = " << PufferLaden50 << endl;
    }
    }

void setup(){
        wiringPiSetup();

        pinMode(DOV1, OUTPUT);
        V1(0);
        pinMode(DOV2, OUTPUT);
        V2(0);
        pinMode(DOV3, OUTPUT);
        V3(0);
        pinMode(DOPumpHW, OUTPUT);
        digitalWrite(DOPumpHW, 1);
        pinMode(DOPumpWT, OUTPUT);
        digitalWrite(DOPumpWT, 1);
        pinMode(DOPumpHK, OUTPUT);
        digitalWrite(DOPumpHK, 1);
        pinMode(DOPumpZirk, OUTPUT);
        digitalWrite(DOPumpZirk, 1);

        pinMode(DIV1S1, INPUT);
        pullUpDnControl(DIV1S1, PUD_DOWN);
        pinMode(DIV1S2, INPUT);
        pullUpDnControl(DIV1S2, PUD_DOWN);
        pinMode(DIV2S1, INPUT);
        pullUpDnControl(DIV2S1, PUD_DOWN);
        pinMode(DIV2S2, INPUT);
        pullUpDnControl(DIV2S2, PUD_DOWN);
        pinMode(DIV3S1, INPUT);
        pullUpDnControl(DIV3S1, PUD_DOWN);
        pinMode(DIV3S2, INPUT);
        pullUpDnControl(DIV3S2, PUD_DOWN);
        }

void ventil(){
    Ventil1soll =2;//Manuelle Vorgabe zum Testen

    while(1){
    V1S1 = digitalRead(DIV1S1);
    V1S2 = digitalRead(DIV1S2);
    V2S1 = digitalRead(DIV2S1);
    V2S2 = digitalRead(DIV2S2);
    V3S1 = digitalRead(DIV3S1);
    V3S2 = digitalRead(DIV3S2);

    if(V1S1 == 0 && V1S2 == 1){Ventil1ist = 1;}
    if(V1S1 == 0 && V1S2 == 0){Ventil1ist = 2;}
    if(V1S1 == 1 && V1S2 == 0){Ventil1ist = 3;}
    if(V2S1 == 0 && V2S2 == 1){Ventil2ist = 1;}
    if(V2S1 == 0 && V2S2 == 0){Ventil2ist = 2;}
    if(V2S1 == 1 && V2S2 == 0){Ventil2ist = 3;}
    if(V3S1 == 0 && V3S2 == 1){Ventil3ist = 1;}
    if(V3S1 == 0 && V3S2 == 0){Ventil3ist = 2;}
    if(V3S1 == 1 && V3S2 == 0){Ventil3ist = 3;}
    cout << "Ventil1Soll  =" <<Ventil1soll <<"   Ventil1ist  =" << Ventil1ist << "  S1= " << V1S1 << "  S2= " << V1S2 << endl;
    usleep(100000);
    if(Ventil1soll != Ventil1ist){
        switch(Ventil1soll){
            case 1:
                V1(1);//Ventilmotor einschalten
                do{ cout << "case1 Ventil1Soll  =" <<Ventil1soll <<"   Ventil1ist  =" << Ventil1ist << endl;
                    usleep(500000);
                    if(V1S1==0){usleep(100000);}//wenn S1 betätigt warte noch ob S2 kommt
                    if(V1S1==0 && V1S2==1){
                        V1(0);
                        break;
                        }
                    }
                while(Ventil1soll == Ventil1ist);
                V1(0);
                cout << "V1=0 case 1 end"<< endl;
                break;
            case 2:
                V1(1);
                do{ cout << "case2 Ventil1Soll  =" <<Ventil1soll <<"   Ventil1ist  =" << Ventil1ist << endl;
                    usleep(500000);
                    if(V1S1==0){usleep(100000);}
                    if(V1S1==0 && V1S2==0){
                        V1(0);
                        break;
                        }
                    }
                while(Ventil1soll == Ventil1ist);
                V1(0);
                cout << "V1=0 case 2 end"<< endl;
                break;
            case 3:
                V1(1);
                do{ cout << "case3 Ventil1Soll  =" <<Ventil1soll <<"   Ventil1ist  =" << Ventil1ist << endl;
                    usleep(500000);
                    if(V1S2==0){usleep(100000);}
                    if(V1S1==1 && V1S2==0){
                        V1(0);
                        break;
                        }
                    }
                while(Ventil1soll == Ventil1ist);
                V1(0);
                cout << "V1=0 case 3 end"<< endl;
                break;
        }
        }
        }
        }


int main(){
    setup();

    thread t1(Einlesen);
    //thread t2(Ablauf);
    //thread t3(Ausgange);

    thread t4(ventil);

    t1.join();
    //t2.join();
    //t3.join();
    t4.join();

    //ausgange();

return 0;
}
;

Display More

Threads

Similar Threads

Parallelisierung von Aufgaben in Python.

Verständnisfrage Zugriffsproblem bash >>

Raspberry Pi OS Bullseye 64bit am Raspi-400 friert plötzlich ein

Users Viewing This Thread