Bagaimanakah Kebuntuan Boleh Dihalang pada Benang STA Apabila Menggunakan StaTaskScheduler dengan Menunggu Menyekat?

StaTaskScheduler dan mesej utas STA mengepam

StaTaskScheduler dalam ParallelExtensionsExtras daripada pasukan Parallel direka untuk mengehoskan objek STA COM legasi yang disediakan oleh pihak ketiga. Perihalan pelaksanaan menyatakan bahawa ia menyokong urutan MTA dan STA dan mengendalikan perbezaan dalam API asas seperti WaitHandle.WaitAll.

Walau bagaimanapun, adalah tidak betul untuk menganggap bahawa StaTaskScheduler akan menggunakan API tunggu yang mengepam mesej (seperti CoWaitForMultipleHandles) untuk mengelakkan kebuntuan pada urutan STA. Bahagian menyekat TPL mungkin tidak mengepam mesej, menyebabkan kebuntuan.

Dalam senario yang dipermudahkan, masalah timbul apabila objek STA COM A dalam proses memanggil objek B di luar proses dan menjangka mendapat panggilan balik daripada B. Panggilan ke a.Method(b) tidak pernah kembali disebabkan oleh menunggu yang menyekat (bukan mengepam mesej) di suatu tempat di dalam BlockingCollection .

Penyelesaian adalah untuk melaksanakan konteks penyegerakan tersuai yang secara eksplisit mengepam mesej menggunakan CoWaitForMultipleHandles dan memasangnya pada setiap urutan STA yang dimulakan oleh StaTaskScheduler.

MsgWaitForMultipleObjectsEx lebih sesuai untuk mengepam mesej daripada CoWaitForMultipleHandles. Kaedah Tunggu konteks penyegerakan tersuai boleh dilaksanakan sebagai pemaju kepada SynchronizationContext.WaitHelper atau mengandungi gelung pengepaman mesej berfungsi sepenuhnya.

Kod berikut menunjukkan pelaksanaan konteks penyegerakan tersuai yang termasuk gelung pengepaman mesej:

<code class="language-c#">// 核心循环
var msg = new NativeMethods.MSG();
while (true)
{
    // 带有 MWMO_INPUTAVAILABLE 的 MsgWaitForMultipleObjectsEx 返回，
    // 即使消息队列中已经看到但未删除消息
    nativeResult = NativeMethods.MsgWaitForMultipleObjectsEx(
        count, waitHandles,
        (uint)remainingTimeout,
        QS_MASK,
        NativeMethods.MWMO_INPUTAVAILABLE);

    if (IsNativeWaitSuccessful(count, nativeResult, out managedResult) || WaitHandle.WaitTimeout == managedResult)
        return managedResult;

    // 有消息，泵送并分派它
    if (NativeMethods.PeekMessage(out msg, IntPtr.Zero, 0, 0, NativeMethods.PM_REMOVE))
    {
        NativeMethods.TranslateMessage(ref msg);
        NativeMethods.DispatchMessage(ref msg);
    }
    if (hasTimedOut())
        return WaitHandle.WaitTimeout;
}</code>

Menggunakan konteks penyegerakan tersuai ini dan gelung pengepaman mesej memastikan mesej dipam walaupun semasa menggunakan sekatan menunggu pada utas STA dan mengelakkan kebuntuan benang STA.

Atas ialah kandungan terperinci Bagaimanakah Kebuntuan Boleh Dihalang pada Benang STA Apabila Menggunakan StaTaskScheduler dengan Menunggu Menyekat?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!