进程绑定到cpu逻辑内核上

Halcom

将线程绑定在某个具体的cpu逻辑内核上运行，[url]https://blog.csdn.net/fm0517/article/details/125470768[/url]

1. using System.Runtime.InteropServices;
   
2. using System.Diagnostics;
   
3. using System.Management;
   
4. 
   
5. namespace BandThreadToCPU
   
6. {
   
7.     class Program
   
8.     {
   
9.         //SetThreadAffinityMask: Set hThread run on logical processer(LP:) dwThreadAffinityMask
   
10.         [DllImport("kernel32.dll")]
    
11.         static extern UIntPtr SetThreadAffinityMask(IntPtr hThread, UIntPtr dwThreadAffinityMask);
    
12. 
    
13.         //Get the handler of current thread
    
14.         [DllImport("kernel32.dll")]
    
15.         static extern IntPtr GetCurrentThread();
    
16. 
    
17.         //The real function
    
18.         public static void ChangeValue(object lpIdx)
    
19.         {
    
20.             //Bind current thread to a specific logical processer
    
21.             ulong LpId = SetCpuID((int)lpIdx);
    
22.             SetThreadAffinityMask(GetCurrentThread(), new UIntPtr(LpId));
    
23. 
    
24.             // Let program run for a while
    
25.             Stopwatch stopwatch = new Stopwatch();
    
26.             stopwatch.Start();
    
27.             for (int i = 0; i < 1000000; i++)
    
28.             {
    
29.                 for (int j = 0; j < 1000000; j++)
    
30.                 {
    
31.                     int _data = j;
    
32.                 }
    
33.             }
    
34.             stopwatch.Stop();
    
35.             Console.WriteLine("Running Time: " + stopwatch.ElapsedMilliseconds.ToString());
    
36.         }
    
37. 
    
38.         //Get CPU id. index:0 -> id:1, 1->2, 2->4, 3->8, 4->16, ...
    
39.         static ulong SetCpuID(int lpIdx)
    
40.         {
    
41.             ulong cpuLogicalProcessorId = 0;
    
42.             if (lpIdx < 0 || lpIdx >= System.Environment.ProcessorCount)
    
43.             {
    
44.                 lpIdx = 0;
    
45.             }
    
46.             cpuLogicalProcessorId |= 1UL << lpIdx;
    
47.             return cpuLogicalProcessorId;
    
48.         }
    
49. 
    
50.         static void Main(string[] args)
    
51.         {
    
52.             // Specify the cpu logical processor index you want. CPU lp index start from 0
    
53.             int LOGICAL_PROCESSOR_IDX = 4;
    
54. 
    
55.             // Get the ManagementClass object
    
56.             ManagementClass mc = new ManagementClass(new ManagementPath("Win32_Processor"));
    
57.             // Get the properties in the class
    
58.             ManagementObjectCollection moc = mc.GetInstances();
    
59. 
    
60.             foreach (ManagementObject mo in moc)
    
61.             {
    
62.                 PropertyDataCollection properties = mo.Properties;
    
63.                 // Print CPU properties
    
64.                 foreach (PropertyData property in properties)
    
65.                 {
    
66.                     Console.WriteLine( property.Name + ": " + property.Value);
    
67.                 }
    
68.             }
    
69. 
    
70.             Stopwatch stopwatch = new Stopwatch();
    
71.             Thread thread = new Thread(new ParameterizedThreadStart(ChangeValue));
    
72.             stopwatch.Start();
    
73.             thread.Start(LOGICAL_PROCESSOR_IDX);
    
74.             thread.Join();
    
75.             stopwatch.Stop();
    
76.             Console.WriteLine("Total running time: " + stopwatch.ElapsedMilliseconds.ToString());
    
77.             Console.ReadKey();
    
78.         }
    
79.     }
    
80. }
    

复制代码