spieleprogrammierer.de - Forum und Wiki zur Spieleprogrammierung und Spieleentwicklung

C#-Quelltext

Engine Engine = new Engine();
Thread EngineThread = new Thread(new ThreadStart(Engine.Start));
EngineThread.Start();

C#-Quelltext

public class Engine
    {
        const int InitThreads = 8;
        int FinishedThreads = 0;
        int Frame;
        bool RunEngine = false;

        private List<Thread> Threads;

        public void Start()//Startet die Engine
        {
            Threads = new List<Thread>();

            if (RunEngine)
                return;
            else
            {
                Frame = 0;
                RunEngine = true;
                EngineLoop();
            }
        }

        public void Cancel()//Schließt die Engine
        {
            RunEngine = false;
        }

        private void EngineLoop()
        {
            while (RunEngine)//Hier ist die Dauerschleife für die Engine
            {
                FinishedThreads = 0; //Kein Thread ist fertig
                for (int i = 0; i < InitThreads; i++)
                {
                    Thread temp = new Thread(PhysicalSimulation); //Alle threads starten
                    Threads.Add(temp);
                    temp.Name = String.Format("Thread [{0}]", i);
                    Console.WriteLine("START: {0}" , i.ToString());
                    temp.Start(i);
                }
                while (FinishedThreads < InitThreads) //Auf alle Threads warten
                    System.Threading.Thread.Sleep(1);

                Threads.Clear();//Frame  fertig, Liste muss sauber werden.

                Frame++;
                Console.WriteLine("==== Frame: {0} Finished ====", + Frame);
            }
            Console.WriteLine("Exit Engine");
        }


        private void PhysicalSimulation(Object o)//Wird später Partikelphysik berechnen
        {
            int n;
            n = (int)o;
            //CountSeparate[n] = 0;

            for (int i = 0; i < (10000000 / InitThreads); i++)
            {
                double d = Math.Sqrt(100000000000); //Irgendwas tun!
                //Die Wurzel wird hier noch ganz oft gezogen, damit es etwas dauert!
            }
            FinishedThreads++; //Fertige Threads hochzählen
            Console.WriteLine("    END: {0}" , n.ToString());
        }
    }

Quellcode

START: 0
START: 1
START: 2
START: 3
END: 2
END: 1
START: 4
END: 0
START: 5
END: 3
START: 6
END: 4
START: 7
END: 5
END: 6
END: 7
==== Frame: 3 Finished ====

C#-Quelltext

FinishedThreads = 0;
for (int i = 0; i < InitThreads; i++)
    ThreadPool.QueueUserWorkItem(PhysicalSimulation, i);

while (FinishedThreads < InitThreads)//Warten dass alle fertig werden
    System.Threading.Thread.Sleep(1);

Quellcode

Enginethread starting
START: 0
    END: 0
All Threads Finished in: 5.662
START: 0
    END: 0
All Threads Finished in: 5.647
START: 0
    END: 0
All Threads Finished in: 2.28
START: 0
    END: 0
All Threads Finished in: 5.678
START: 0
    END: 0
All Threads Finished in: 2.28
START: 0

Exit Signal recieved
    END: 0
All Threads Finished in: 5.725
Exit Engine

C#-Quelltext

ThreadPool.UnsafeQueueUserWorkItem()

C#-Quelltext

while (FinishedThreads < Config.InitThreads)//Warten dass alle fertig werden //GEHT SO NICHT 
    System.Threading.Thread.Sleep(1);