Muti Threading In For/Foreach and DataTable example

class Program
{
      static void Main(string[] args)
      {
             Threader t = new Threader();
             List<string> lst = new List<string>();
             for (int i = 0; i < 1000; i++)
                   lst.Add("number " + i);
             t.RunThreadsWithControl(lst, 110);
             t.PrintPrintedList();        //just to oversee that all numbers got printed
            Console.WriteLine("Done");
            Console.ReadKey();
      }
}
class Threader
{
        List<bool> globalThreadsFinished;        
        public bool AllThreadsFinished
       {
            get
           {
                  foreach (bool item in globalThreadsFinished)
                       if (!item)
                           return false;
                  return true;
            }
        }
        
        List<string> printedList;
        public void PrintPrintedList()
        {
                foreach (string s in printedList)
                      Console.WriteLine(s);
        }
       
        public void RunThreadsWithControl(List<string> list, int threadsAtOneTime)
        {
               printedList = new List<string>();
               for (int i = 0; i < list.Count; i++)
               {
                      int j = i;
                      globalThreadsFinished = new List<bool>();
                      while (j < list.Count)
                     {
                              if ((i + threadsAtOneTime) >= list.Count)
                                   threadsAtOneTime = list.Count - i;
                              globalThreadsFinished.Add(false);
                              int boolIndex = globalThreadsFinished.Count - 1;
                              string value = list[j];
                              Thread t = new Thread(() => HandleSingleThread(value , boolIndex));
                              t.Start();
                              if ((j + 1) >= (i + threadsAtOneTime))
                                     break;
                              ++j;
                    }
               
                    while (!AllThreadsFinished)
                    {
                            Thread waitThread = new Thread(() => WaitThread(100));
                            waitThread.Start();
                            waitThread.Join();
                    }

                     //this is optional, just to actualy see that the app actualy waits for stops
                     Console.WriteLine("AllThreadsFinished");
                     Thread waitThread2 = new Thread(() => WaitThread(1500));
                     waitThread2.Start();
                     waitThread2.Join();
                   
                     //back to the must               
                     globalThreadsFinished.Clear();
                     i = j;
              }
        }
            
        void HandleSingleThread(string s, int boolIndex)
        {
                 if (!printedList.Contains(s))
                          printedList.Add(s);
                 for (int i = 0; i < 100; i++)
                          Console.WriteLine(s);
                 globalThreadsFinished[boolIndex] = true;
        }
       
        void WaitThread(int mls)
        {
                Thread.Sleep(mls);
        }
     }
}

remember that if HandleSingleThread is calling sub-method u should probably make them as threads too cuz otherwise the program might cross-thread with them and u wont notice, and best to do there Thread.Join().
P.S. - just to state the obvious - the lst from Main can be DataTable.Rows, and just send a DataRow or ANY enumerator (da) and handle it right in your SingleThread method

also for the protocol this works too:
class Program
{
       static void Main(string[] args)
      {
            int max = 5;
            Thread[] tArr = new Thread[max];
            for (int i = 0; i < max; i++)
            {
                  int i2 = i;
                  tArr[i] = new Thread(() => Print(i2.ToString()));
                  tArr[i].Start();
            }
            for (int i = 0; i < max; i++)
            {
                  tArr[i].Join();
            }
            Console.WriteLine("Done");
            Console.ReadKey();
      }

      static void Print(string str)
     {
           for (int i = 0; i < 10; i++)
           Console.WriteLine(str);
     }
}
if u use this it is advised to run tArr and make them all null or stuff gets slow

Comments

Post a Comment

Popular posts from this blog

OverTheWire[.com] Natas Walkthrough - JUST HINT, NO SPOILERS

game portal: http://overthewire.org/wargames/natas/ PASSWORDS for each level are stored in /etc/natas_webpass/natasX I made this walkthrough for people like me, i needed some help, but didnt want the spoiler, so here i will give you all the information needed to pass each level, yet not the solution. For levels needed custom web request i made a different post for powershell and javascript  with how-to's, since is a piece of learning for itself, and also for those of us that play at work and have only powershell at their hands. Although its not a complete spoiler there, its quite most of the solution so try yourself 1st. Natas The Natas game is from basic to advances web hacking. Every few levels is about whole new exploitation (with some harder ones doing comeback later), so a lot of learning. If you're new, you're the reason i am writing so much even for the 1st level, just please google EVERY topic you see, since in the following levels i assume you know the ...
Read more

Asp.Net Ending Response options, Response.End() vs CompleteRequest()

this blog is for any1 who get the ThreadAbortException when caling Response.End(), and then tried the other options such as HttpContext.Current.ApplicationInstance.CompleteRequest() and found out that there was no replacement. i'll start with the bottom line: if you want to stop right now your response and send it as is you dont have any other option other than Response.End(), period and it's the right thing to throw that EX in that case. the answer is its because there is the "HTTP pipeline" and the "Asp.Net pipeline", and CompleteRequest() cuts the HTTP pipeline but not the Asp.Net one so everything that is from handlers forwars (including all page events) continues but your part, the asp one, stays in your hands so that no information will be lost, so ur suppose to manage your code currectly, since information lost is really a bad thing, although in most cases we use Response.End() we know what we are losing and we want it. see this short article ab...
Read more

SOLVED The item could not be indexed successfully because the item failed in the indexing subsystem

if you got an error like this The item could not be indexed successfully because the item failed in the indexing subsystem. ( The item could not be indexed successfully because the item failed in the indexing subsystem.; Failed to recover content group; Aborting insert of item in Link Database because it was not inserted to the Search Index.; ; SearchID = 04081656-B51B-4DCD-96D4-6DB2D2CEEEE7 ) as well as these: The item could not be indexed successfully because the item failed in the indexing subsystem. ( The item could not be indexed successfully because the item failed in the indexing subsystem.; Caught exception when preparing generation GID[7]: (Previous generation (last=GID[6], curr=GID[7]) is still active. Cannot open GID[7]); Aborting insert of item in Link Database because it was not inserted to the Search Index.; ; SearchID = 92EB0180-C086-4853-BED8-F4878D9748AD ) the solution for me was to clear configuration cache (PS)  and then restart SP Search Services. THX ...
Read more