Task Klasse : Eine List aus Tasks mit Parameter und Rückgabewerten

Hallo,
leider bisher nicht ganz so fündig geworden.

Ich schreibe gerade an einer Klasse die mir Task (Kommunikation) verwaltet bzw. parallelisiert.
Ist das hier Thread sicher? Mir geht es um das Datenübergeben?
Wo ich mich gerade gar nicht hinaus sehe wie bekomme die Streams in die Liste ?

	static class Scheduler
	{
		static private IModel _model;
		static private PLCProvider _provider;
		static private List<Task> taskList;
		static private List<byte[]> streamList = new List<byte[]>();

		static public void Start_PAE(List<PLCTyp> plcList)
		{
			taskList = new List<Task>();
		
			foreach( PLCTyp plc in plcList)
			{
				Task task = new Task((myData) => 
				{
					PLCTyp c = (PLCTyp)myData;
.........
......
					
				},plc);
				taskList.Add(task);

			}
			Task.WaitAll(taskList.ToArray());

		}

		static public void Stop()
		{
			
		}
	}

Erklärt doch erst mal, was Du überhaupt tun willst.
Eigentlich gibt es fast kein Grund irgendeinen Task Scheduler selbst zu schreiben.

Und wenn man mit Tasks arbeitet, sollte man auch immer (wenn möglich) asynchron arbeiten.
WaitAll gilt als Pitfall.

Also zur Erklärung, Ich habe einen Controller geschrieben der via TCP/IP mit Maschinen kommunizieren soll.

Eine Controller Instanz arbeitet Sequentiell Anfragen ab( Die Anzahl ist Variable).

jetzt kann es eben mehrer Controller bzw. Maschinen geben.

Die Abarbeitung sollte sehr schnell von statten gehen, daher soll jeder Controller auf einen Task ausgelagert werden.

Jedem Task muss ich anfangs die Verbindungsdaten übergeben und anschließend sollte der empfangene Stream zurück geliefert werden.
Wenn alle Tasks beendet sind wird ein Skript gestartet.

Warum muss ein Controller das Wissen eines Tasks haben?

Im Prinzip hast Du nur ein simplen Data Flow.
Dafür gibt es zig umsetzungsweisen, zB. Walkthrough: Creating a Dataflow Pipeline bzw. Dataflow (Task Parallel Library)

Gerade (Netzwerk-)Kommunikationen sollten aber unbedingt asynchron sein!

Warum muss ein Controller das Wissen eines Tasks haben?

Ich glaube hier kommt gerade was durcheinander, die Benennungen sind evtl. noch nicht so eindeutig....

Zyklisch werden alle Daten von den Maschinen gelesen und nur wenn alle Lesevorgänge Fertig sind darf mit den empfangen Daten weiter gearbeitet werden.

Diese Daten werden anschließend für eine Skript gebraucht.

Ist das Skript abgearbeitet werden die aktualisierte Daten zu den Maschinen gesendet.
Stur nach dem EVA Prinzip, das muss umbedingt eingehalten werden.

Ich könnte jetzt Sequenziell jede Maschine nach einander abfragen, nur das würde zulange dauern.
Ich hoffe ich hab das jetzt verständlich rüber gebracht.

Ich habs das von mir gerade noch vervollständigt, evtl erkennt man jetzt besser was gemeint ist

static class Scheduler
	{
		static private IModel _model;
		static private List<Task> taskList;
		static private List<byte[]> streamList = new List<byte[]>();

		static public void Start_PAE(List<PLCTyp> plcList)
		{
			taskList = new List<Task>();
		
			foreach( PLCTyp plc in plcList)
			{
				Task task = new Task((myData) => 
				{
					PLCTyp c = (PLCTyp)myData;
					PLCWorker worker = new PLCWorker(c);
					worker.Connect();
					var recv = worker.Read(); //sollte zurück geliefert werden
			
				},plc);
			
				taskList.Add(task);

			}
			Task.WaitAll(taskList.ToArray());

		}

Ich bin da jetzt auch kein Experte, aber wenn ich mir nur die Beispiele im zweiten von Abt verlinkten Artikel so anschaue, sieht das nach exakt dem aus, was Du brauchst. Die Ausführungsblöcke dürften besonders spannend sein.

Schau dir das doch einfach Mal an, bestimmt klären sich dabei einige Fragen, immerhin bist Du laaaaangeee nicht der Erste mit dieser Problemstellung.

Palladin, ist es auch.
Aber er möchte vermutlich eher Sturr seine Basis weiter führen, statt es mit einem stabilen, etablierten Pattern zu machen - jedenfalls mein Eindruck.

Ne mit stur hat das nicht zu tun, ich kannte das eben bisher nicht. Ich hatte so eine Problemstellung bisher auch nicht zum bewältigen. Ich hatte auch gedacht die Task Parallel lib läst es nicht zu daten zu übergeben und anschließend Daten zurück zulieferer. Ich werde mir das aber auf alle Fälle mal ansehen, danke!
Grüße

Natürlich geht das. Dazu gibt es Task<T> bzw. Task.Result.
Aber deine ganze Herangehensweise ist, wie schon mehrfach erläutert, nicht zu empfehlen. Lies dir doch mal einen Artikel zu Asyncroner Programmierung bzw. async/await durch, dann würden sich solche Fragen von allein beantworten. Du solltest bei soetwas nicht davon ausgehen, daß du der erste bist, der vor einem solchen Problem steht.

Meine aktuelle Lektüre hat mich eigentlich dazu gebracht... aber ja ich teste diese Example Projekte mal und schaue mir das mal genauer an.

Ich weiß auch gerade nicht ob ich bei mir noch von Asynchron sprechen kann weil ich umbedingt warten das alle Threads fertig sind.

Bitte les Dir die Grundlagen durch.
Asynchrone und parallele Programmierung sind zwei paar Stiefel. Wenn Dir das unbekannt ist, dann solltest Du erst mal mit Kapitel 1 beginnen.

Man kann genauso asynchron auf parallele Aktionen warten, aber eben asynchron mit WhenAll und nicht blockierend mit WaitAll.
Aber mit einem entsprechenden Datenfluss brauchst Du eigentlich überhaupt kein Warten, sondern kannst mit Continue arbeiten.

Und Kommunikation-Code sollte immer asynchron sein.
Ich hab Dir die Artikel nicht aus Langeweile gegeben. Wenn Du nur stocherst, dann knallt Dein Code mit Anlauf.