如何结合RTWQ API使用IAudioClient3(WASAPI)及代码问题排查

你遇到的AUDCLNT_E_BUFFER_TOO_LARGE错误和音频异常，主要来自三个核心问题：WASAPI缓冲区操作逻辑错误、RTWQ工作项的重复提交问题，以及COM接口实现不规范。下面逐一拆解并给出修复方案：

1. 错误的缓冲区请求大小 #

在共享模式下，InitializeSharedAudioStream的第二个参数MINP是音频引擎的周期帧数量（即每次事件触发时，需要填充的帧数量），而GetBufferSize返回的是整个环形缓冲区的总帧数量。你在Invoke中每次请求整个缓冲区大小的帧，这完全不符合WASAPI的工作逻辑：

• 第一次调用时，缓冲区是空的，能成功填充全部帧；
• 第二次事件触发时，音频引擎已经播放了MINP帧，此时空闲缓冲区只有MINP帧，请求全部缓冲区大小必然返回AUDCLNT_E_BUFFER_TOO_LARGE。

修复：将GetBuffer的请求帧数量改为引擎周期MINP，而不是缓冲区总大小。你可以把MINP保存到类成员中，供Invoke使用。

2. RTWQ工作项的错误提交方式 #

你的thread_main循环中反复调用workqueue->queue(hEvent)，这会重复提交同一个工作项到队列，导致事件触发时多个Invoke实例并发执行，进一步加剧缓冲区操作冲突。正确的做法是：在一次回调执行完毕后，再重新提交工作项，而不是在主循环中反复提交。

修复：修改my_rtqueue::Invoke方法，在完成缓冲区操作后，重新调用RtwqPutWaitingWorkItem绑定事件，确保下一次事件触发时能再次执行回调。同时，移除主循环中的workqueue->queue(hEvent)调用，只在初始化时提交一次工作项。

3. 不规范的COM接口实现 #

你的IRtwqAsyncCallback实现中，QueryInterface直接返回0，AddRef/Release返回0，这违反了COM的引用计数规则，会导致COM对象生命周期管理错误，可能引发内存泄漏或崩溃。

修复：正确实现QueryInterface，处理IID_IUnknown和IID_IRtwqAsyncCallback的查询；同时维护一个引用计数变量，正确实现AddRef和Release。

修正后的核心代码示例 #

修正后的my_rtqueue类 #

class my_rtqueue : IRtwqAsyncCallback {
private:
    LONG m_cRef = 1; // COM引用计数
    IRtwqAsyncResult* pAsyncResult = nullptr;
    RTWQWORKITEM_KEY workItemKey = 0;
    DWORD WorkQueueId = 0;
    HANDLE m_hEvent = nullptr;
    UINT32 m_periodFrames = 0; // 保存引擎周期帧数量
    IAudioRenderClient* m_pRenderClient = nullptr; // 持有渲染客户端引用

public:
    // 构造函数增加必要参数
    my_rtqueue(HANDLE hEvent, UINT32 periodFrames, IAudioRenderClient* pRenderClient) 
        : m_hEvent(hEvent), m_periodFrames(periodFrames) {
        HRESULT hr = S_OK;
        DWORD taskId = 0;

        // 锁定Pro Audio工作队列
        hr = RtwqLockSharedWorkQueue(L"Pro Audio", 0, &taskId, &WorkQueueId);
        ERROR_THROW(hr);

        // 创建异步结果
        hr = RtwqCreateAsyncResult(nullptr, this, nullptr, &pAsyncResult);
        ERROR_THROW(hr);

        // 持有渲染客户端引用
        m_pRenderClient = pRenderClient;
        m_pRenderClient->AddRef();

        // 首次提交工作项
        hr = RtwqPutWaitingWorkItem(m_hEvent, 1, pAsyncResult, &workItemKey);
        ERROR_THROW(hr);
    }

    STDMETHODIMP GetParameters(DWORD* pdwFlags, DWORD* pdwQueue) {
        *pdwFlags = 0;
        *pdwQueue = WorkQueueId;
        return S_OK;
    }

    STDMETHODIMP Invoke(IRtwqAsyncResult* pAsyncResult) {
        HRESULT hr = S_OK;
        BYTE* pData = nullptr;

        // 请求引擎周期大小的缓冲区
        hr = m_pRenderClient->GetBuffer(m_periodFrames, &pData);
        if (FAILED(hr)) {
            goto Cleanup;
        }

        // 填充音频数据：帧数量为m_periodFrames，对应2通道的样本数
        update_buffer((unsigned short*)pData, m_periodFrames * 2);

        hr = m_pRenderClient->ReleaseBuffer(m_periodFrames, 0);
        ERROR_EXIT(hr);

    Cleanup:
        // 重新提交工作项，等待下一次事件触发
        if (SUCCEEDED(hr)) {
            hr = RtwqPutWaitingWorkItem(m_hEvent, 1, this->pAsyncResult, &workItemKey);
        }
        return hr;
    }

    // 正确实现COM接口
    STDMETHODIMP QueryInterface(const IID &riid, void **ppvObject) {
        if (!ppvObject) return E_POINTER;
        *ppvObject = nullptr;

        if (riid == IID_IUnknown || riid == IID_IRtwqAsyncCallback) {
            *ppvObject = static_cast<IRtwqAsyncCallback*>(this);
            AddRef();
            return S_OK;
        }
        return E_NOINTERFACE;
    }

    ULONG AddRef() {
        return InterlockedIncrement(&m_cRef);
    }

    ULONG Release() {
        LONG cRef = InterlockedDecrement(&m_cRef);
        if (cRef == 0) {
            if (m_pRenderClient) m_pRenderClient->Release();
            delete this;
        }
        return cRef;
    }

    HRESULT stop() {
        HRESULT hr = S_OK;

        // 取消工作项
        if (workItemKey != 0) {
            hr = RtwqCancelWorkItem(workItemKey);
            workItemKey = 0;
        }

        if (pAsyncResult) {
            pAsyncResult->Release();
            pAsyncResult = nullptr;
        }

        if (WorkQueueId != 0xFFFFFFFF) {
            hr = RtwqUnlockWorkQueue(WorkQueueId);
            WorkQueueId = 0xFFFFFFFF;
        }

        return hr;
    }

    ~my_rtqueue() = default;
};

修正后的thread_main核心部分 #

// ... 省略前面的初始化代码 ...

UINT32 DP, FP, MINP, MAXP;
hr = pAudioClient->GetSharedModeEnginePeriod(&wave_format, &DP, &FP, &MINP, &MAXP);
printf("DefaultPeriod: %u, Fundamental period: %u, min_period: %u, max_period: %u\n", DP, FP, MINP, MAXP);

hr = pAudioClient->InitializeSharedAudioStream(AUDCLNT_STREAMFLAGS_EVENTCALLBACK, MINP, &wave_format, 0);

// ... 省略缓冲区大小获取等代码 ...

hEvent = CreateEvent(nullptr, false, false, nullptr);
if (hEvent == INVALID_HANDLE_VALUE) {
    ERROR_EXIT(0);
}

hr = pAudioClient->SetEventHandle(hEvent);

// 创建RTWQ工作队列，传入事件、周期帧数量、渲染客户端
my_rtqueue* workqueue = nullptr;
try {
    workqueue = new my_rtqueue(hEvent, MINP, pRenderClient);
} catch (...) {
    hr = E_ABORT;
    ERROR_EXIT(hr);
}

// ... 启动音频客户端 ...

hr = pAudioClient->Start(); // Start playing.
running = 1;

// 主循环仅等待停止信号，不再提交工作项
while (running) {
    Sleep(100); // 避免空转占用CPU，可替换为事件等待逻辑
}

// 停止工作队列和音频客户端
workqueue->stop();
hr = pAudioClient->Stop();

// ... 省略清理代码 ...

额外注意事项 #

• 共享模式下，虽然Win10+的WASAPI有显著改进，但低延迟场景仍建议优先考虑独占模式（如果硬件支持）；
• 使用AvSetMmThreadCharacteristics设置线程优先级时，确保你的线程确实需要该优先级，避免影响系统稳定性；
• 所有COM对象的释放要遵循正确顺序，避免内存泄漏。

内容的提问来源于stack exchange，提问作者ehoopz