Source Code for Me (s-c.me)

Copy Source | Copy HTML

1. public class MainTests
2. {
3.     //количество ошибок по результату выполнения
4.     public static int iErrors = 0;
5.  
6.     private static ManualResetEvent[] resetEvents;
7.  
8.     /// <summary>
9.     /// Запускаем одновременно NumThreads потоков
10.     /// </summary>
11.     /// <param name="NumThreads">Число потоков</param>
12.     public void QueueFewRequests(int NumThreads, AskTo whereto)
13.     {
14.         ManualResetEvent oStart = new ManualResetEvent(false);
15.         Debug.WriteLine("-------------QueueFewRequests = " + NumThreads.ToString() + " " + whereto.ToString() + "----------");
16.         resetEvents = new ManualResetEvent[NumThreads];
17.         for (int i = 0; i < NumThreads; i++)
18.         {
19.             resetEvents[i] = new ManualResetEvent(false);
20.             if (!ThreadPool.UnsafeQueueUserWorkItem(new WaitCallback(MakeSingleSearch),
21.                 new ThreadParam()
22.                 {
23.                     number = i,
24.                     oEvent = resetEvents[i],
25.                     oWhenStart = oStart,
26.                     askto = whereto
27.                 }))
28.             {
29.                 MainTests.iErrors++;
30.                 System.Diagnostics.Debug.WriteLine("Cant Queue request!");
31.                 break;
32.             }
33.         }
34.         //let it go!
35.         oStart.Set();
36.         if (NumThreads < 64)
37.         {
38.             ManualResetEvent.WaitAll(resetEvents);
39.         }
40.         else
41.         {
42.             //если элементов меньше 64, то можно использовать ManualResetEvent.WaitAll(resetEvents);
43.             Array.ForEach(resetEvents, new Action<ManualResetEvent>(WaitFinish));
44.         }
45.         Assert.AreEqual(0, MainTests.iErrors);
46.     }
47.  
48.     private void WaitFinish(ManualResetEvent oEvent)
49.     {
50.         oEvent.WaitOne();
51.     }
52.  
53.     /// <summary>
54.     /// Передаем один запрос в службу
55.     /// </summary>
56.     /// <param name="stateInfo"></param>
57.     static void MakeSingleSearch(Object stateInfo)
58.         {
59.             Random rand = new Random(DateTime.Now.Millisecond + ((ThreadParam)stateInfo).number);
60.  
61.             if (stateInfo != null)
62.             {
63.                 //дождемся команды начала работы    
64.                 ((ThreadParam)stateInfo).oWhenStart.WaitOne();
65.                 int iRand = (int)Math.Floor(rand.NextDouble() * 1000)+100;
66.                 try
67.                 {
68.                     DSTLCode dCode;
69.                     PerformanceTimer timer = new PerformanceTimer();
70.                     timer.StartTimer();
71.                     //определимся с запросом
72.                     AskTo whatwedo = ((ThreadParam)stateInfo).askto;
73.                     switch (whatwedo)
74.                     {
75.                         ...
76.                     }
77.                      Debug.WriteLine("Thread " +
78.                         ((ThreadParam)stateInfo).number + " - " + dCode.ToString() + " " +
79.                         " for '" + iRand.ToString() + "' successed in " + timer.StopTimer().ToString() + " sec");
80.  
81.  
82.                 }
83.                 catch(Exception e1)
84.                 {
85.                     iErrors++;
86.                     Debug.WriteLine("Thread " +
87.                         ((ThreadParam)stateInfo).number + " - Ошибка обработки: " + e1.Message);
88.                 }
89.                 finally
90.                 {
91.                     //передаем информацию о том, что мы завершили работу
92.                     ((ThreadParam)stateInfo).oEvent.Set();
93.                 }
94.             }
95.         }
96.     }