Managed C++/CLI

#include "stdafx.h"<br />
<br />
using namespace System;<br />
using namespace System::Threading;<br />
<br />
public ref class SomeState{<br />
public: <br />
     int Cookie;<br />
public:<br />
     SomeState(int iCookie)<br />
     {<br />
          Cookie = iCookie;<br />
     }<br />
};<br />
<br />
public ref class Alpha{<br />
public:<br />
     array<int>^ HashCount; <br />
     ManualResetEvent^ eventX;<br />
     static int iCount;<br />
<br />
     static int iMaxCount;<br />
     Alpha(int MaxCount) <br />
     {<br />
          iCount = 0;<br />
          HashCount = gcnew array<int>(30);<br />
          iMaxCount = MaxCount;<br />
     }<br />
<br />
     //   The method that will be called when the Work Item is serviced<br />
     //   on the Thread Pool<br />
public:<br />
     void Beta(Object^ state)<br />
     {<br />
          Console::WriteLine(" {0} {1} :", Thread::CurrentThread->GetHashCode(), (dynamic_cast<SomeState^>(state))->Cookie);<br />
          Interlocked::Increment(HashCount[Thread::CurrentThread->GetHashCode()]);<br />
<br />
          //   Do some busy work<br />
          int iX = 10000;<br />
          while (iX > 0){ iX--;}<br />
          if (Interlocked::Increment(iCount) == iMaxCount) {<br />
               Console::WriteLine("Setting EventX ");<br />
               eventX->Set();<br />
          }<br />
     }<br />
};<br />
<br />
public class SimplePool<br />
{<br />
public:<br />
     static int Main(array<System::String ^> ^args)<br />
<br />
     {<br />
          Console::WriteLine("Thread Simple Thread Pool Sample");<br />
          int MaxCount = 1000;<br />
          ManualResetEvent^ eventX = gcnew ManualResetEvent(false);<br />
          Console::WriteLine("Queuing {0} items to Thread Pool", MaxCount);<br />
          Alpha^ oAlpha = gcnew Alpha(MaxCount);<br />
          oAlpha->eventX = eventX;<br />
          Console::WriteLine("Queue to Thread Pool 0");<br />
          SomeState^ sstate0=gcnew SomeState(0);<br />
          ThreadPool::QueueUserWorkItem(gcnew WaitCallback(oAlpha->Beta),sstate0);<br />
          for (int iItem=1;iItem < MaxCount;iItem++)<br />
          {<br />
               Console::WriteLine("Queue to Thread Pool {0}", iItem);<br />
               SomeState^ sstatei=gcnew SomeState(iItem);<br />
               ThreadPool::QueueUserWorkItem(gcnew WaitCallback(oAlpha->Beta),     sstatei);<br />
          }<br />
          Console::WriteLine("Waiting for Thread Pool to drain");<br />
          eventX->WaitOne(Timeout.Infinite,true);<br />
          Console::WriteLine("Thread Pool has been drained (Event fired)");<br />
          Console::WriteLine("Load across threads");<br />
          for(int iIndex=0;iIndex<oAlpha->HashCount->Length;iIndex++)<br />
               Console::WriteLine("{0} {1}", iIndex, oAlpha->HashCount[iIndex]);<br />
          return 0;<br />
     }<br />
};

using System;<br />
using System.Threading;<br />
<br />
public class SomeState{<br />
  public int Cookie;<br />
  public SomeState(int iCookie){<br />
    Cookie = iCookie;<br />
  }<br />
};<br />
<br />
<br />
public class Alpha{<br />
  public int [] HashCount;<br />
  public ManualResetEvent eventX;<br />
  public static int iCount = 0;<br />
  public static int iMaxCount = 0;<br />
  public Alpha(int MaxCount) {<br />
    HashCount = new int[30];<br />
    iMaxCount = MaxCount;<br />
  }<br />
<br />
<br />
   //   The method that will be called when the Work Item is serviced<br />
   //   on the Thread Pool<br />
   public void Beta(Object state){<br />
     Console.WriteLine(" {0} {1} :", <br />
               Thread.CurrentThread.GetHashCode(), ((SomeState)state).Cookie);<br />
     Interlocked.Increment(ref HashCount[Thread.CurrentThread.GetHashCode()]);<br />
<br />
     //   Do some busy work<br />
     int iX = 10000;<br />
     while (iX > 0){ iX--;}<br />
     if (Interlocked.Increment(ref iCount) == iMaxCount) {<br />
       Console.WriteLine("Setting EventX ");<br />
       eventX.Set();<br />
     }<br />
  }<br />
};<br />
<br />
public class SimplePool{<br />
  public static int Main(String[] args)   {<br />
    Console.WriteLine("Thread Simple Thread Pool Sample");<br />
    int MaxCount = 1000;<br />
    ManualResetEvent eventX = new ManualResetEvent(false);<br />
    Console.WriteLine("Queuing {0} items to Thread Pool", MaxCount);<br />
    Alpha oAlpha = new Alpha(MaxCount);<br />
    oAlpha.eventX = eventX;<br />
    Console.WriteLine("Queue to Thread Pool 0");<br />
    ThreadPool.QueueUserWorkItem(new WaitCallback(oAlpha.Beta),new SomeState(0));<br />
       for (int iItem=1;iItem < MaxCount;iItem++){<br />
         Console.WriteLine("Queue to Thread Pool {0}", iItem);<br />
         ThreadPool.QueueUserWorkItem(new WaitCallback(oAlpha.Beta),<br />
                                   new SomeState(iItem));<br />
       }<br />
    Console.WriteLine("Waiting for Thread Pool to drain");<br />
    eventX.WaitOne(Timeout.Infinite,true);<br />
    Console.WriteLine("Thread Pool has been drained (Event fired)");<br />
    Console.WriteLine("Load across threads");<br />
    for(int iIndex=0;iIndex<OALPHA.HASHCOUNT.LENGTH;IINDEX++)<br />
      Console.WriteLine("{0} {1}", iIndex, oAlpha.HashCount[iIndex]);<br />
    }<br />
    return 0;<br />
  }<br />
}