java - Windows C++ 相当于 Java 的 LockSupport.parkNanos()

Question

我需要在 Win7 x64 上实现与此功能相同的功能。

我最初使用 SwitchToThread() 但这不起作用，因为它在极端条件下会导致死锁。我能找到的唯一选择是 Sleep() 但这很可能是一个性能 killer ，因为它只适用于毫秒分辨率，而且我仍然不确定它是否与 LockSupport 做同样的事情.parkNanos().

我发现 Java 在纳秒间隔内安排(如果发生这种情况)线程的能力令人怀疑，所以我实现了我只能假设它们做的事情......自旋。但是我不确定这是否解决了问题，它可能只是推迟了不可避免的事情，因为 Java 函数似乎需要 JVM 的干预才能工作。 parkNanos 的源代码不可用；它在 native Sun 库中实现。

class LockSupport
{
public:
    static void ParkNanos(unsigned __int64 aNanos)
    {
        ULONGLONG start;
        ULONGLONG end;

        ::QueryUnbiasedInterruptTime(&start);
        do
        {
            // My issue with this is that nothing is actually 'Parked'.
            ::SwitchToThread();
            ::QueryUnbiasedInterruptTime(&end);
        }
        while ((end - start) < aNanos);
    }
};

调用代码如下所示:

void SomeClass::SomeFunction()
{
    while (someCond)
    {
        LockSupport.parkNanos(1L);
    }
}

FWIW，我正在将 LMAX 的 Disruptor 模式移植到 C++。当一个线程处于 SingleThreadedClaimStrategy::WaitForFreeSlotAt() 而另一个线程处于 BlockingWaitStrategy::WaitFor(无超时)时，就会发生死锁。当 RingBuffer 大小很小...1、2、4、8 等时，死锁更加明显。

线程是通过普通的CreateThread方式创建的。

编辑:我写这篇文章的时候已经很晚了，所以这里有一些更多的信息。RingBuffer 包含 __int64。我有一个生产者线程和一个消费者线程。 Consumer 线程还产生一个 Timer 线程，该线程每秒轮询 Consumer 以获取它上次消费的事件的序列号。有时消费者没有取得任何进展，生产者也没有完成。生产者只是循环运行几亿次发布一个计数器。所以我的输出看起来像这样:

898
97
131
Timer: no progress
Timer: no progress
...

它只有在 Release模式下才能真正重现，一切都针对速度进行了优化。

Answer 1

除了能够 unpark() 一个线程，LockSupport.parkNanos(...) 只不过是一个 sleep 。在 Windows 上的 OpenJDK 热点 VM 中，它是 implemented (第 4436 行)使用 WaitForSingleObject(...)，并至少 hibernate 1 毫秒。

LMAX disruptor 似乎从未unpark() 线程。因此，您应该通过调用 Sleep(1) 获得等效的行为。使用 Sleep(0) 可能会做得更好:放弃当前线程中的剩余时间片，并可以立即重新安排。这等同于 SwitchToThread()，但后者可能只是告诉您“还没有准备好运行，因此您可以保留 cpu”。另一方面，如果您的调度粒度足够低，Sleep(1) 实际上可能会暂停 1 毫秒。

在remarks到 Sleep() 需要注意的是，您可以通过调用 timeBeginPeriod() 来改进系统的调度粒度(可能低至每滴答 1 毫秒) .