ManualResetEvent无法正常工作;线

Question

我有一个创建线程的客户端。

该线程有一个WaitOne()所以当它被卡在那里我的客户端不会死。但是当我想关闭我的客户端时，我需要在手动重置事件上做一个Set()。

我在主类中声明了手动重置事件：

public ManualResetEvent mreIn = new ManualResetEvent(false);

这是我的Connect函数，它使用start函数创建线程：

    public void Connect()
    {
        objClientThread = new Thread(start) { IsBackground = true };
        objClientThread.Start();
    }

    /// <summary>
    /// Starts the client program.
    /// </summary>
    private void start()
    {
            //We Open the proxy to let connections happen
            objProxy.Open();
            if (performHandshake())
            {
                IsConnected = true;
                DelayedShutdownBool = false;
                //While connected, the thread keeps the client alive
                mreIn.WaitOne();
                if (OnShutdownInitiated != null)
                {
                    OnShutdownInitiated(this, new EventArgs());
                }
                System.Threading.Thread.Sleep(500);
                objProxy.Close();
                objConfiguration = null;
                IsConnected = false;
                mreOut.Set();
            }
        }

我有一个回调，它做Set()：

    Boolean IServiceCallbackContract.Shutdown()
    {
        mreIn.Set();
        return true;
    }

所以它的工作方式是......所有模块都在WaitOne()上被初始化和阻塞当我关闭一个模块时，回调执行Set()但是WaitOne()没有解锁而且线程没有继续。我错过了什么？

Answer 1

问题是，当我创建服务客户端时，我不得不传递回调的instace上下文，而我正在做一个new，所以我没有放入current实例上下文，并且回调正在对其他实例进行，所以每个我正在做的值或事件的变化没有反映在当前的情况中。谢谢@HenkHolterman的帮助:)

Answer 2

看起来你正在以正确的方式使用ManualResetEvent。但是，你的主题是背景。如果所有其他非后台线程退出，那么您的线程将在随机位置中止，并且mreIn.WaitOne()之后的代码可能无法执行。

如果是这种情况，那么让你的头脑没有背景将解决问题。

Answer 3

请注意这个例子：

class ThreadManager : IThreadManager
{
    private System.Threading.ManualResetEvent _Mre;
    private static CancellationTokenSource _CancellationToken;
    private int _ThreadCount;

    public ThreadManager(int threadCount)
    {
        _Mre = new System.Threading.ManualResetEvent(true);
        _CancellationToken = new CancellationTokenSource();
        _ThreadCount = threadCount;
    }

    public void DoWork(Action action)
    {
        _Mre.WaitOne();
        Task.Factory.StartNew(action, _CancellationToken.Token);
    }

    public void Stop()
    {
        _CancellationToken.Cancel();
    }

    public void Resume()
    {
        _Mre.Set();
    }

    public void Waite()
    {
        _Mre.Reset();
    }
}