Блог

Создание фонового потока в C # обычным способом —

 Thread t = new Thread(....);
t.IsBackground = true;
t.Start();
etc etc
  

Хочу вызвать CancelSynchronousIO из основного потока, чтобы отменить блокирующий вызов ввода-вывода в фоновом потоке. Не знаю, как получить дескриптор потока в форме IntPtr для передачи функции:

 [DllImport("kernel32.dll", SetLastError=true)]
static extern bool CancelSynchronousIo(IntPtr threadHandle);
  

Кажется, существуют различные способы получения идентификатора потока, но не дескриптора? И способы получения идентификатора потока, похоже, дают вам идентификатор только в управляемой среде, так что нет смысла в вызовах PInvoke? Я предполагаю, что я что-то упускаю.

Нужно ли мне выполнять другие вызовы PInvoke, чтобы получить дескриптор потока, или есть более простой способ?

Вы можете это сделать, но это настоятельно не рекомендуется.

 using System;
using System.Diagnostics;
using System.Runtime.InteropServices;
using System.Threading;

class Program
{
    [DllImport("kernel32.dll", SetLastError = true)]
    static extern uint GetCurrentThreadId();

    [DllImport("kernel32.dll", SetLastError = true)]
    static extern IntPtr OpenThread(uint desiredAccess, bool inheritHandle, uint threadId);

    [DllImport("kernel32.dll", SetLastError = true)]
    static extern bool CloseHandle(IntPtr handle);

    [DllImport("kernel32.dll", SetLastError = true)]
    static extern bool CancelSynchronousIo(IntPtr threadHandle);

    static bool CancelSynchronousIo(uint threadId)
    {
        // GENERIC_WRITE, Non-inheritable
        var threadHandle = OpenThread(0x40000000, false, (uint)threadId);
        var ret = CancelSynchronousIo(threadHandle);

        CloseHandle(threadHandle);

        return ret;
    }

    static void Main(string[] args)
    {
        uint threadId = 0;

        using (var threadStarted = new AutoResetEvent(false))
        {
            var thread = new Thread(() =>
            {
                try
                {
                    Thread.BeginThreadAffinity();
                    threadId = GetCurrentThreadId();

                    threadStarted.Set();

                    // will throws System.OperationCanceledException
                    Console.ReadLine();
                }
                finally
                {
                    Thread.EndThreadAffinity();
                }
            });

            thread.Start();

            threadStarted.WaitOne();
        }

        Debugger.Break();

        CancelSynchronousIo(threadId);
    }
}