“对象同步方法是从非同步的代码块中调用的”回调测试错误

Question

如果收到了预期数量的异步回调，则应该测试以下类：

class Program
{
    static List<int> callbackObjects = new List<int>();
    static int expectedNumberOfCallbacks;
    static void Main(string[] args)
    {
        expectedNumberOfCallbacks = 10;
        Monitor.Enter(callbackObjects);
        CallbackTest.CallbackTester.TriggerCallbacks(expectedNumberOfCallbacks,Callback);
        Monitor.Wait(callbackObjects,10000);
        Assert.AreEqual(callbackObjects.Count, expectedNumberOfCallbacks);
    }

    private static void Callback(int callbackObject)
    {
        callbackObjects.Add(callbackObject);
        Console.WriteLine($"Callback number {callbackObjects.Count}");
        if(callbackObjects.Count == expectedNumberOfCallbacks)
        {
            Monitor.Exit(callbackObjects);
        }
    }
}

代码输出，

Callback number 1
Callback number 2
Callback number 3
Callback number 4
Callback number 5
Callback number 6
Callback number 7
Callback number 8
Callback number 9
Callback number 10

但随后会抛出一个

System.Threading.SynchronizationLockException: 'Object synchronization method was called from an unsynchronized block 

执行权，

Monitor.Exit(callbackObjects);

是因为Monitor.enter.enter.enter和monitor.exit 在不同的范围/线程中调用？

如何重写代码，

Assert.AreEqual(callbackObjects.Count, expectedNumberOfCallbacks)

在收到预期的回调数或预定义超时之后，在main中进行测试？

Answer 1

是因为monitor.enter和Monitor.exit在不同的范围/线程中调用？

是的，正是那样。 Monitor是线程的。

但是，IMO您还应该考虑是否可以重叠多个回调；如果是，则需要在回调内同步，以便callbackobjects.add定义很好。您的真正需要的是lock pulse ：

   static void Main(string[] args)
    {
        expectedNumberOfCallbacks = 10;
        lock (callbackObjects)
        {
            CallbackTest.CallbackTester.TriggerCallbacks(
                expectedNumberOfCallbacks,Callback);
            Monitor.Wait(callbackObjects, 10000);
            Assert.AreEqual(callbackObjects.Count, expectedNumberOfCallbacks);
        }
    }

    private static void Callback(int callbackObject)
    {
        lock (callbackObjects)
        {
            callbackObjects.Add(callbackObject);
            Console.WriteLine($"Callback number {callbackObjects.Count}");
            if(callbackObjects.Count == expectedNumberOfCallbacks)
            {
                Monitor.Pulse(callbackObjects);
            }
        }
    }

等待发布监视器和等待信号或超时重新启动它； pulse和pulseall是将该信号发送到等待线程（或线程）的原因。

您还可以使用等待的返回值来确定是否发出信号（vs timeout）。