对每个方法的自定义核心/线程数并行执行两个方法

Question

有没有办法指定每个方法使用的核心/线程数并且不阻塞它们。 例子： 我有方法A和方法B。 方法 A 会被调用 50 次，方法 B 也会被调用。

假设我有一个 16 核的 CPU。 我想将其委托给方法 A 它将并行使用 2 个线程，而方法 B 将使用 4 个线程并且不会阻塞它们。 我尝试过使用信号量，但在任务执行后它们会阻塞和释放。

这里是一些示例代码： 注意：threadService 方法只是调用 Thread.Sleep 3 秒

static void Main(string[] args)
    {
        ThreadService threadService = new ThreadService();

        for (int i = 0; i < 5; i++)
        {
            Task t = Task.Run(() => threadService.RunFirstMethod());
        }

        for (int i = 0; i < 5; i++)
        {
            Task t = Task.Run(() => threadService.RunSecondMethod());
        }

        Console.ReadLine();
    }

也许这不是一个好主意...？任何帮助或建议将不胜感激。 谢谢。

信号量的第一次尝试（不行）：

static void Main(string[] args)
    {
        ThreadService threadService = new ThreadService();

        Semaphore semaphoreFirstMethod = new Semaphore(2, 2);
        for (int i = 0; i < 5; i++)
        {
            semaphoreFirstMethod.WaitOne();
            Task t = Task.Run(() => threadService.RunFirstMethod()).ContinueWith(s => semaphoreFirstMethod.Release());
        }

        Semaphore semaphoreSecondMethod = new Semaphore(2,2);
        for (int i = 0; i < 5; i++)
        {
            semaphoreSecondMethod.WaitOne();
            Task t = Task.Run(() => threadService.RunSecondMethod()).ContinueWith(s => semaphoreSecondMethod.Release());
        }
        Console.ReadLine();
    }

结果如下：

   2018-08-25 15:34:17.7259 INFO RunFirstMethod()
2018-08-25 15:34:17.7259 INFO RunFirstMethod()
2018-08-25 15:34:19.7691 INFO RunFirstMethod()
2018-08-25 15:34:19.7691 INFO RunFirstMethod()
2018-08-25 15:34:21.7775 INFO RunFirstMethod()
2018-08-25 15:34:21.7775 INFO RunSecondMethod()
2018-08-25 15:34:21.7775 INFO RunSecondMethod()
2018-08-25 15:34:23.8053 INFO RunSecondMethod()
2018-08-25 15:34:23.8053 INFO RunSecondMethod()
2018-08-25 15:34:25.8211 INFO RunSecondMethod()

在@mjwills 建议使用 sempahores 发布代码后，我发现我没有做应有的事情， 信号量的第二次实现：

static void Main(string[] args)
    {
        ThreadService threadService = new ThreadService();

        Task.Run(() =>
        {
            Semaphore semaphore = new Semaphore(2, 2);
            for (int i = 0; i < 5; i++)
            {
                semaphore.WaitOne();
                Task t = Task.Run(() => threadService.RunFirstMethod()).ContinueWith(s => semaphore.Release());
            }
        });

        Task.Run(() =>
        {
            Semaphore semaphore = new Semaphore(2, 2);
            for (int i = 0; i < 5; i++)
            {
                semaphore.WaitOne();
                Task t = Task.Run(() => threadService.RunSecondMethod()).ContinueWith(s => semaphore.Release());
            }
        });
        Console.ReadLine();
    }

第二个结果（对我来说没问题）：

    2018-08-25 15:36:01.0845 INFO RunSecondMethod()
2018-08-25 15:36:01.0855 INFO RunFirstMethod()
2018-08-25 15:36:02.0863 INFO RunFirstMethod()
2018-08-25 15:36:03.0783 INFO RunSecondMethod()
2018-08-25 15:36:03.1386 INFO RunSecondMethod()
2018-08-25 15:36:03.1386 INFO RunFirstMethod()
2018-08-25 15:36:04.0938 INFO RunFirstMethod()
2018-08-25 15:36:05.0877 INFO RunSecondMethod()
2018-08-25 15:36:05.1547 INFO RunSecondMethod()
2018-08-25 15:36:05.1677 INFO RunFirstMethod()

Answer 1

感谢大家的帮助。我通过运行两个任务完成了解决方案。我需要 2 种方法来并行运行并控制每个方法的线程数） 线程数由信号量控制。 示例：

static void Main(string[] args)
{
    ThreadService threadService = new ThreadService();

    Task.Run(() =>
    {
        Semaphore semaphore = new Semaphore(2, 2);
        for (int i = 0; i < 5; i++)
        {
            semaphore.WaitOne();
            Task t = Task.Run(() => threadService.RunFirstMethod()).ContinueWith(s => semaphore.Release());
        }
    });

    Task.Run(() =>
    {
        Semaphore semaphore = new Semaphore(2, 2);
        for (int i = 0; i < 5; i++)
        {
            semaphore.WaitOne();
            Task t = Task.Run(() => threadService.RunSecondMethod()).ContinueWith(s => semaphore.Release());
        }
    });
    Console.ReadLine();
}

Answer 2

最简单的方法是添加一些调度逻辑，根据线程逻辑索引决定执行哪个方法：

var threadService = new ThreadService();
Parallel.For(
    0, 6,
    index =>
    {
        if (index < 4)
            threadService.RunFirstMethod();
        else
            threadService.RunSecondMethod();
    });

但是，这并不能保证一个方法将在同一个核心上独占执行。要实现这一点，您需要指定线程-CPU 亲和性，这对于 .NET 来说有点棘手，因为它在系统线程之上使用自己的线程，这些线程只是可以应用 CPU 亲和性的线程。这是good article，它解释了如何通过外部调用来完成这项工作。