应用程序中有多少个线程？如何设置信号量？

Question

信号量意味着指定一次可以进入关键区域的线程数量。

设置计数下面的代码是5

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Threading; 
using System.Threading.Tasks; 

namespace ConsoleApp1 
{ 
    class Program 
    { 
     static Semaphore semaphore = new Semaphore(5, 5); 
     static void Main(string[] args) 
     { 
      Task.Factory.StartNew(() => 
      { 
       for (int i = 1; i <= 15; ++i) 
       { 
        PrintSomething(i); 
        if (i % 5 == 0) 
        { 
         Thread.Sleep(2000); 
        } 
       } 
      }); 
      Console.ReadLine(); 
     } 

     public static void PrintSomething(int number) 
     { 
      semaphore.WaitOne(); 
      Console.WriteLine(number); 
      semaphore.Release(); 
     } 
    } 
} 

每一次我们可以有5个线程在任何时间运行的手段。打印结果验证该点。

我的问题是，我没有看到这么多的线程运行。说15个线程运行，每次只能让5个线程共存。只有两个线程。

我误解了一些东西？

Answer 1

您使用Task.Factory.StartNew()开始一个额外的线程，就是这样。在那个线程中，你依次调用PrintSomething()方法，所以你的线程输出截图是正确的。

如下更改代码：

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Threading; 
using System.Threading.Tasks; 

namespace SempahoreTest1 
{ 
    class Program 
    { 
    static Semaphore semaphore = new Semaphore(5, 5); 

    static void Main(string[] args) 
    { 
     for (int i = 1; i <= 15; ++i) 
     { 
     Task.Factory.StartNew((state) => 
     { 
      int number = (int)state; 

      PrintSomething(number); 
      if (i % 5 == 0) 
      { 
      Thread.Sleep(2000); 
      } 
     }, i); 
     } 
     Console.ReadLine(); 
    } 

    public static void PrintSomething(int number) 
    { 
     semaphore.WaitOne(); 
     try 
     { 
     Console.WriteLine("Thread: {0}, Number: {1}", Thread.CurrentThread.ManagedThreadId, number); 
     } 
     finally 
     { 
     semaphore.Release(); 
     } 
    } 
    } 
} 

更新：

一个更好的解释，如何旗语的作品，应该是：

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Threading; 
using System.Threading.Tasks; 

namespace SempahoreTest1 
{ 
    class Program 
    { 
    static Semaphore semaphore = new Semaphore(5, 5); 
    static Random random = new Random(); 

    static void Main(string[] args) 
    { 
     Parallel.For(1, 16, PrintSomething); 

     Console.ReadLine(); 
    } 

    public static void PrintSomething(int number) 
    { 
     semaphore.WaitOne(); 
     try 
     { 
     Console.WriteLine("Thread: {0}, Number: {1}, Access granted", Thread.CurrentThread.ManagedThreadId, number); 
     // sleep to simulate long running method 
     Thread.Sleep(random.Next(1000, 5000)); 
     } 
     finally 
     { 
     semaphore.Release(); 
     Console.WriteLine("Thread: {0}, Number: {1}, Semaphore released", Thread.CurrentThread.ManagedThreadId, number); 
     } 
    } 
    } 
} 

并行循环从调用PrintSomething()不同的线程。每次调用信号量计数器都会减少，直到达到0. PrintSomething()的下一个调用块将在semaphore.WaitOne()上阻塞，直到第一次调用semaphore.Release()，这会再次增加信号量计数器。等等...... 前5次调用非常快，因为最大信号计数（5）可用。然后，由于不同的睡眠时间，方法调用输出会显示信号灯的工作方式。