1

私はMutexを実験していて、次のコードを書きました。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace Mutex_WaitOnewithTimeouts
{
    class Program
    {
        private static Mutex mut = new Mutex();
        private static int numOfThreads = 5;
        private static int numOfIterations = 3;
        private static Random rand = new Random();

        static void Main(string[] args)
        {
            Thread[] threads = new Thread[5];
            for (int num = 0; num < numOfThreads; num++)
            {
                threads[num] = new Thread(new ThreadStart(MyThreadProc));
                threads[num].Name = String.Format("Thread{0}", num);
                threads[num].Start();
            }
            Console.Read();
        }

        private static void MyThreadProc()
        {
            for (int iteration = 0; iteration < numOfIterations; iteration++)
            {
                UseResource();
            }
        }

        private static void UseResource()
        {
            Console.WriteLine("{0} accessing ", Thread.CurrentThread.Name);
            int time = (int)(rand.NextDouble() * 100);
            try
            {
                if (mut.WaitOne(time))
                {
                    Console.WriteLine("Yippie got mutex for {0}", Thread.CurrentThread.Name);
                    Thread.Sleep((int)rand.NextDouble() * 5000);
                }
                else
                {
                    Console.WriteLine("Nopee.... Timeout occured for {0}", Thread.CurrentThread.Name);
                }
            }
            catch (AbandonedMutexException ex)
            {
                Console.WriteLine(" Exception is caught");
            }
            finally 
            {
                Console.WriteLine("Releasing mutex for {0}", Thread.CurrentThread.Name);
               mut.ReleaseMutex();

            }

        }
    }
}

しかし、ApplicationExceptionが発生することがあります。コードに問題がある場合は、誰かが私を助けてくれますか。また、この例外がいつトリガーされるかを説明してください。

オブジェクト同期メソッドは、同期されていないコードブロックから呼び出されました。ミューテックスを解放しようとすると、finallyブロックでこれを取得しています。

4

2 に答える 2

7

WaitOneが失敗した場合でも、ミューテックスを解放しています。ミューテックスを取得したことがわかっているifステートメント内でReleaseMutex呼び出しを移動します。

于 2012-05-01T18:46:35.647 に答える
0

@ジョンの答えは正しいですが、後世のために、より良いパターンは、ブール値をtrueに設定してからif、releaseブロック内でfinally実行することですが、今回はブール値がtrueの場合にのみ実行すると思います。問題は、if句のいずれかがスローされた場合、ミューテックスが解放されないことです。if書き込みとスリープだけでなく、句にさらに追加することになると思います。

可能であれば常にパターンを使用したいのですが、 false を返す呼び出しtry { ... } finallyから保護するだけです。waitOne()次のようなもの：

bool release = false;
try {
    if (mut.waitOne(time)) {
        release = true;
        ...
    } else {
        ...
    }
} catch (AbandonedMutexException ex) {
    ...
} finally {
    ...
    if (release) {
        mut.ReleaseMutex();
    }
}
于 2012-05-01T19:25:33.683 に答える