C#. Creating own threads

example shows

– thread statictics

-start thread without params

-start thread with params

-waiting of Thread which starts other threads… with AutoResetEvent handle

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading;
using System.Windows.Forms;

namespace ThreadStats
{
    class Program
    {

        private static AutoResetEvent waitHandle = new AutoResetEvent(false);

        static void Main(string[] args)
        {
            //PrimaryThreadStats();
           // ThreadStartExample();
            ThreadStartWithParams();

        }

        public static void ThreadStartExample()
        {
            Console.WriteLine("*** Amasing Thread App ***\n");
            Console.Write("Do you want [1] or [2] threads?");
            string threadCount = Console.ReadLine();

            Thread primaryThread = Thread.CurrentThread;
            primaryThread.Name = "Primary";

            Console.WriteLine("-> {0} is executing Main()", Thread.CurrentThread.Name);

            Printer p = new Printer();

            switch (threadCount)
            {
                case "2":
                    Thread backgroundThread = new Thread(new ThreadStart(p.PrintNumbers));
                    backgroundThread.Name = "Secondary";
                    backgroundThread.Start();
                    waitHandle.WaitOne(); // << main thread will wait !!!
                    break;

                case "1":
                    p.PrintNumbers();
                    break;
                default:
                    Console.WriteLine("I don't know what you want you get 1 thread");
                    goto case "1";
            }
            MessageBox.Show("I am buisy!", "Work on main thread...");
            Console.ReadLine();
        }



        public class Printer
        {

            public void PrintNumbers()
            {
                Console.WriteLine("-> {0} is executing PrintNumbers()",Thread.CurrentThread.Name);
                Console.WriteLine("Your Numbers:");
                for (int i = 0; i < 10; i++)
                {
                    Console.Write("{0}, ",i);
                    Thread.Sleep(2000);
                   
                }
                Console.WriteLine();
                waitHandle.Set(); // stop waiting for waiting thread
            }
        }

        static void PrimaryThreadStats()
        {
            Thread t = Thread.CurrentThread;
            t.Name = "PrimaryThread";
            Console.WriteLine("Name of current AppDomain:{0}",Thread.GetDomain().FriendlyName);
            Console.WriteLine("ID of current context:{0}", Thread.CurrentContext.ContextID);
            Console.WriteLine("ThreadName:{0}", t.Name);
            Console.WriteLine("Is Alive?:{0}", t.IsAlive);
            Console.WriteLine("Priority:{0}", t.Priority);
            Console.WriteLine("ThreadState:{0}", t.ThreadState);
            Console.ReadLine();
        }


        class AddParams
        {
            public int a, b;
            public AddParams(int n1,int n2)
            {
                a = n1;
                b = n2;
            }
        }

        static void Add(object data)
        {
            if (data is AddParams)
            {
                Console.WriteLine("ID of thread in Add():{0}",Thread.CurrentThread.ManagedThreadId);
                AddParams p = (AddParams)data;
                Console.WriteLine("{0}+{1} is {2}",p.a,p.b,p.a+p.b);
                waitHandle.Set();
            }
        }

        public static void ThreadStartWithParams()
        {
            AddParams p = new AddParams(10, 10);
            Thread t = new Thread( new ParameterizedThreadStart(Add));
            t.Start(p);
            //Thread.Sleep(5); // rough approach
            waitHandle.WaitOne();
            Console.WriteLine("Other thread is done");
            Console.ReadLine();
        }

    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using System.Threading;

using System.Windows.Forms;

namespace ThreadStats

{

class Program

{

private static AutoResetEvent waitHandle = new AutoResetEvent(false);

static void Main(string[] args)

{

//PrimaryThreadStats();

// ThreadStartExample();

ThreadStartWithParams();

}

public static void ThreadStartExample()

{

Console.WriteLine("*** Amasing Thread App ***\n");

Console.Write("Do you want [1] or [2] threads?");

string threadCount = Console.ReadLine();

Thread primaryThread = Thread.CurrentThread;

primaryThread.Name = "Primary";

Console.WriteLine("-> {0} is executing Main()", Thread.CurrentThread.Name);

Printer p = new Printer();

switch (threadCount)

{

case "2":

Thread backgroundThread = new Thread(new ThreadStart(p.PrintNumbers));

backgroundThread.Name = "Secondary";

backgroundThread.Start();

waitHandle.WaitOne(); // << main thread will wait !!!

break;

case "1":

p.PrintNumbers();

break;

default:

Console.WriteLine("I don't know what you want you get 1 thread");

goto case "1";

}

MessageBox.Show("I am buisy!", "Work on main thread...");

Console.ReadLine();

}

public class Printer

{

public void PrintNumbers()

{

Console.WriteLine("-> {0} is executing PrintNumbers()",Thread.CurrentThread.Name);

Console.WriteLine("Your Numbers:");

for (int i = 0; i < 10; i++)

{

Console.Write("{0}, ",i);

Thread.Sleep(2000);

}

Console.WriteLine();

waitHandle.Set(); // stop waiting for waiting thread

}

static void PrimaryThreadStats()

{

Thread t = Thread.CurrentThread;

t.Name = "PrimaryThread";

Console.WriteLine("Name of current AppDomain:{0}",Thread.GetDomain().FriendlyName);

Console.WriteLine("ID of current context:{0}", Thread.CurrentContext.ContextID);

Console.WriteLine("ThreadName:{0}", t.Name);

Console.WriteLine("Is Alive?:{0}", t.IsAlive);

Console.WriteLine("Priority:{0}", t.Priority);

Console.WriteLine("ThreadState:{0}", t.ThreadState);

Console.ReadLine();

}

class AddParams

{

public int a, b;

public AddParams(int n1,int n2)

{

a = n1;

b = n2;

}

static void Add(object data)

{

if (data is AddParams)

{

Console.WriteLine("ID of thread in Add():{0}",Thread.CurrentThread.ManagedThreadId);

AddParams p = (AddParams)data;

Console.WriteLine("{0}+{1} is {2}",p.a,p.b,p.a+p.b);

waitHandle.Set();

}

public static void ThreadStartWithParams()

{

AddParams p = new AddParams(10, 10);

Thread t = new Thread( new ParameterizedThreadStart(Add));

t.Start(p);

//Thread.Sleep(5); // rough approach

waitHandle.WaitOne();

Console.WriteLine("Other thread is done");

Console.ReadLine();

}

MY PROJECTS

Recent Posts

Categories