c# - 方法的并行访问

Question

(那里的任何人)

我正在研究车辆跟踪系统:- 我有 n 辆公共(public)汽车说 b1t1(早上 7 点开始，晚上 7 点停止)
bt2(早上8点开始，晚上8点停止)和bt3(早上9点开始，晚上9点停止)
，其中 t 是公交车的开始时间

现在我在列表中有这样的总线。
现在，对于列表中的每辆巴士，我选择一个巴士对象并传递给方法 MyMethod(bus bt)；我想要的是，我想将 b1、b2、b3 传递给 MyMethod(bus bt)，并且每辆巴士都说 b1--开始自己处理 MyMethod(bus bt)
然后对于 b2 -- 启动它自己的 MyMethod(bus bt) 处理
然后对于 b3----开始它自己的 MyMethod(bus bt) 处理
所有 b1 b2 b3 都应该在那里开始自己的并行处理(必须是线程安全的——我不知道使用线程安全这个词是否合适)...

---我尝试使用线程，但线程不能并行访问该方法...

---

更多解释我只有一种方法，将在循环中将总线对象一个一个地传递给 MyMethod(bus bt) ...但我希望线程 t1/t2 ...tn 应该并行访问此方法...因为当线程用于b1 正在同时运行 b2 的线程应该运行。

enter c public bool SchedulerEntryPointFunction()
    {
        Console.WriteLine("Scheduler is  initiated !\n\n");
        bool bSuccess = false;

        Console.WriteLine("Got ActiveBuses and coresponding Paths!\n\n");
        List<ActiveBusAndItsPathInfo> ActiveBusAndItsPathInfoList = BusinessLayer.GetActiveBusAndItsPathInfoList();
        if (ActiveBusAndItsPathInfoList != null)
        {
            Thread[] threads = new Thread[ActiveBusAndItsPathInfoList.Count];
            while (true)
            {
                foreach (ActiveBusAndItsPathInfo ActiveBusAndItsPathInfoObj in ActiveBusAndItsPathInfoList)
                {
                    //Get curent time
                    //compare for time difference less than equal to 5 mins
                    if (ActiveBusAndItsPathInfoObj.isSMSThreadActive == false)
                    {
                        // Console.WriteLine("SMS Thread about to initiate!\n\n");

                        DateTime CurrentTime = System.DateTime.Now;
                        // TimeSpan CurrentTimespan = (TimeSpan)CurrentTime;
                        DateTime Bustime = Convert.ToDateTime(ActiveBusAndItsPathInfoObj.busObj.Timing);
                        //TimeSpan BustimeTimes = Bustime.TimeOfDay;
                        TimeSpan tsa = Bustime - CurrentTime;

                        //  if(tsa.TotalMinutes > 0 && tsa.TotalMinutes < 5)
                        {
                            ActiveBusAndItsPathInfoObj.isSMSThreadActive = true;

                            ***ThreadStart starter = delegate { SMSThreadEntryPointFunction(ActiveBusAndItsPathInfoObj); };
                            Thread t = new Thread(starter);
                           **//  t.Start();
                            int indexOfCurrentActiveBusAndItsPathInfoObj = ActiveBusAndItsPathInfoList.IndexOf(ActiveBusAndItsPathInfoObj);
                            threads[indexOfCurrentActiveBusAndItsPathInfoObj] = new Thread(starter);
                            threads[indexOfCurrentActiveBusAndItsPathInfoObj].Start();
                            threads[indexOfCurrentActiveBusAndItsPathInfoObj].Join();***
                        }
                    }
                }**


            }
        }

        return bSuccess;
    }

点此

---

新代码:- 仍然存在同步问题...

  foreach (ActiveBusAndItsPathInfo ActiveBusAndItsPathInfoObj in ActiveBusAndItsPathInfoList)
                       {
                        //Get curent time
                        //compare for time difference less than equal to 5 mins
                        if (ActiveBusAndItsPathInfoObj.isSMSThreadActive == false)
                        {

                            DateTime CurrentTime = System.DateTime.Now;
                           DateTime Bustime = Convert.ToDateTime(ActiveBusAndItsPathInfoObj.busObj.Timing);
                            TimeSpan tsa = Bustime - CurrentTime;

                            if(tsa.TotalMinutes > 0 && tsa.TotalMinutes < 5)
                            {
                                ActiveBusAndItsPathInfoObj.isSMSThreadActive = true;

                                ThreadPool.QueueUserWorkItem(state => SMSThreadEntryPointFunction(ActiveBusAndItsPathInfoObj)

                        }
                    }


                }
            }

            return bSuccess;
        }

我是否必须锁定我的方法...SMSThreadEntryPointFunction(ActiveBusAndItsPathInfoObj)

---

目前我正在尝试

 ThreadPool.QueueUserWorkItem(new WaitCallback(SMSThreadEntryPointFunction), (object)ActiveBusAndItsPathInfoObj);

但给出错误:-“SMSThreadEntryPointFunction 的重载不匹配委托(delegate) system.thread.WaitCallback”

(那里的任何人)

Answer 1

ThreadPool.QueueUserWorkItem(state => MyMethod(bus1));
ThreadPool.QueueUserWorkItem(state => MyMethod(bus2));
...