信号量动态调整大小 C#

Question

我试图使用信号量来控制可以同时运行的作业实例的数量。虽然这对于等待方法来说相当简单，但我还希望该值可以在运行时配置，以便我可以向上或向下增加计数。

我意识到倒计时可能会出现问题，但有没有办法真正做到这一点？这是使用信号量的正确方法吗？

Answer 1

根据 ReleaseSemaphore 的文档，对于 lReleaseCount 参数：

信号量对象当前计数要增加的量。该值必须大于零。 如果指定的数量会导致信号量的计数超过创建信号量时指定的最大计数，则计数不会更改并且函数返回 FALSE。

这和其他文档表明信号量对于您的限制来说不是正确的选择。信号量一旦创建，就会有一个硬性最大值，如果不重新创建信号量就无法更改该最大值。换句话说，它不是一个可以更改的动态值。

在这种情况下，您需要找到另一种方法来管理您的限制。

使用信号量的一种方法是分配一个足够大的信号量来满足所有未来的需求，然后获取足够的“实例”以减少可用的信号量数量回到您目前需要的数量。当您想要增加可用实例的数量时，只需释放您一开始就获取的一些实例即可。

但是，我质疑你为什么要这样做。真正决定你可以同时执行多少个作业的限制因素是什么？信号量很可能不是这个问题的正确答案。

Answer 2

虽然使用等待方法相当简单，但我还希望该值可以在运行时配置，以便我可以向上或向下增加计数。

我不建议为此使用信号量。

如果您使用 .NET 4，我建议的方法是创建一个自定义 TaskScheduler 允许您在运行时更改并发级别。然后，您可以使用在选项中传递此 TaskScheduler 的单个 Parallel.For/ForEach 调用来运行整个操作，并在运行时更改并发级别。

这将使处理向上或向下移动级别变得相当容易。当级别上升时，您只需根据需要添加新线程即可。当它们出现故障时，只需从内部集合中删除该线程（但不要停止它），并让它完成当前的工作。这将允许您根据需要进行扩展。

Answer 3

根据Lasse V. Karlsen的建议，我在kotlin中实现了一个动态信号量。我不知道如何在 C# 中做到这一点，但应该相当相似。只需将其视为伪代码答案即可。

该代码具有以下行为：

• 您可以创建信号量，如果您从不更新它，它将完全像信号量一样工作

• 增加许可证将释放许可证最多 100 个（随意增加最大值）

• 当仍有大量许可证时减少许可证是即时的

• 当当前发放的许可证多于新的允许限制时减少许可证最终将减少许可证，从而允许进程自行完成。在达到目标许可证之前不会发放新许可证

   const val maximalSize = 100
  
    私有 val DynamicSemaphoreSingleton = DynamicSemaphore(maximalSize)
  
    fun getDynamicSemaphoreSingleton（允许：Int）：DynamicSemaphore {
        返回 DynamicSemaphoreSingleton.also { it.updatePermits(permits) }
    }
  
    类 DynamicSemaphore(private var 允许: Int) : 信号量 {
        private val backingSemaphore = Semaphore(maximalSize, maximalSize - 允许)
  
        私有变量 extraAcquires = 0
  
        有趣的 updatePermits(newPermits: Int) {
            val 差异 = newPermits - 许可
  
            如果（差值<0）{
                val numberOfFailedAcquires =
                    List(-difference) { backingSemaphore.tryAcquire() }.count { it.not() }
  
                同步(this) { extraAcquires += numberOfFailedAcquires }
            } 别的 {
                重复(差异) { backingSemaphore.release() }
            }
            许可证 = 新许可证
        }
  
        覆盖 val availablePermits: Int
            get() = backingSemaphore.availablePermits
  
        覆盖挂起乐趣获取（）{
            backingSemaphore.acquire()
        }
  
        覆盖 funrelease() {
            同步（这个）{
                if (extraAcquires > 0) {
                    额外获得——
                } 别的 {
                    backingSemaphore.release()
                }
            }
        }
  
        重写 fun tryAcquire(): Boolean {
            返回 backingSemaphore.tryAcquire()
        }
    }