0

JI は Visual Studio 2008 で .NET C# Windows フォーム アプリを作成しました。これは、[開始] ボタンが押されたときにセマフォを使用して複数のジョブをスレッドとして実行します。

40 分以上実行した後、フォームがコンマに入るという問題が発生しています。ログ ファイルは、現在のジョブが完了したことを示し、リストから新しいジョブを選択し、そこでハングします。

これが発生すると、Windows フォームが応答しなくなることに気付きました。フォームは独自のスレッドで実行されています。

これは私が使用しているコードのサンプルです:

protected void ProcessJobsWithStatus (Status status)
        {
int maxJobThreads = Convert.ToInt32(ConfigurationManager.AppSettings["MaxJobThreads"]);
            Semaphore semaphore = new Semaphore(maxJobThreads, maxJobThreads);  // Available=3; Capacity=3


            int threadTimeOut = Convert.ToInt32(ConfigurationManager.AppSettings["ThreadSemaphoreWait"]);//in Seconds
            //gets a list of jobs from a DB Query.
List<Job> jobList = jobQueue.GetJobsWithStatus(status);
            //we need to create a list of threads to check if they all have stopped.
            List<Thread> threadList = new List<Thread>();
            if (jobList.Count > 0)
            {
                foreach (Job job in jobList)
                {
                    logger.DebugFormat("Waiting green light for JobId: [{0}]", job.JobId.ToString());
                    if (!semaphore.WaitOne(threadTimeOut * 1000))
                    {
                        logger.ErrorFormat("Semaphore Timeout. A thread did NOT complete in time[{0} seconds]. JobId: [{1}] will start", threadTimeOut, job.JobId.ToString());

                    }

                    logger.DebugFormat("Acquired green light for JobId: [{0}]", job.JobId.ToString());
                    // Only N threads can get here at once    
                    job.semaphore = semaphore;
                    ThreadStart threadStart = new ThreadStart(job.Process);

                    Thread thread = new Thread(threadStart);
                    thread.Name = job.JobId.ToString();
                    threadList.Add(thread);
                    thread.Start();


                }

                logger.Info("Waiting for all threads to complete");

                //check that all threads have completed.
                foreach (Thread thread in threadList)
                {
                    logger.DebugFormat("About to join thread(jobId): {0}", thread.Name);
                    if (!thread.Join(threadTimeOut * 1000))
                    {
                        logger.ErrorFormat("Thread did NOT complete in time[{0} seconds]. JobId: [{1}]", threadTimeOut, thread.Name);
                    }
                    else {
                        logger.DebugFormat("Thread did complete in time. JobId: [{0}]", thread.Name);
                    }
                }                   

            }

            logger.InfoFormat("Finished Processing Jobs in Queue with status [{0}]...", status);

}

//フォームメソッド

private void button1_Click(object sender, EventArgs e)
        {
            buttonStop.Enabled = true;
            buttonStart.Enabled = false;

            ThreadStart threadStart = new ThreadStart(DoWork);
            workerThread = new Thread(threadStart);

            serviceStarted = true;
            workerThread.Start();



        }

private void DoWork()
        {
            EmailAlert emailAlert = new EmailAlert ();
            // start an endless loop; loop will abort only when "serviceStarted" flag = false
            while (serviceStarted)
            {  
                emailAlert.ProcessJobsWithStatus(0);

                // yield
                if (serviceStarted)
                {
                    Thread.Sleep(new TimeSpan(0, 0, 1));
                }
            }

            // time to end the thread
            Thread.CurrentThread.Abort();
        }

//ジョブ.プロセス()

 public void Process()
        {
             try
            {

                //sets the status, DateTimeStarted, and the processId
                this.UpdateStatus(Status.InProgress);

                //do something

                logger.Debug("Updating Status to [Completed]");

                //hits, status,DateFinished
                this.UpdateStatus(Status.Completed);

            }
            catch (Exception e)
            {
                logger.Error("Exception: " + e.Message);
                this.UpdateStatus(Status.Error);

            }
            finally {
                logger.Debug("Relasing semaphore");
                semaphore.Release();
            }

問題が発生している場所を検出するために、できることをファイルに記録しようとしましたが、これまでのところ、問題が発生している場所を特定できませんでした。Windows フォームの制御を失うと、これはジョブの処理とは何の関係もないと思います。何か案は？

解決策: RedGate ANTS でプロファイリングすると、問題が発生していました。直接実行すると発生しません。

4

1 に答える 1

3

私が最初に目にするのはあなたのThread.CurrentThread.Abort()電話です。これは不要です。関数を終了させると、スレッドは正常にシャットダウンします。

2 つ目に気付いたのは、セマフォの取得でタイムアウトが発生しても、スレッドが作成されるということです。スレッドが多すぎると、フォームがハングする可能性があります。

logger.DebugFormat("Waiting green light for JobId: [{0}]", job.JobId.ToString());
if (!semaphore.WaitOne(threadTimeOut * 1000))
{
   logger.ErrorFormat("Semaphore Timeout. A thread did NOT complete in time[{0} seconds]. JobId: [{1}] will start", threadTimeOut, job.JobId.ToString());
   // Should have exit here.
}
logger.DebugFormat("Acquired green light for JobId: [{0}]", job.JobId.ToString());

3 つ目は、ワーカー スレッドが、ジョブ ループ内のすべてのジョブに対して単純にスレッドを作成する関数を呼び出していることです。ジョブが完了しない場合 (そのコードがどこにも表示されないため、ジョブがキューから削除されると仮定します)、DoWork がスリープ状態から復帰する前に、同じジョブを反復処理して別のジョブを作成しようとします。それのためのスレッド。

于 2010-03-11T16:43:36.680 に答える