AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • Início
  • system&network
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • Início
  • system&network
    • Recentes
    • Highest score
    • tags
  • Ubuntu
    • Recentes
    • Highest score
    • tags
  • Unix
    • Recentes
    • tags
  • DBA
    • Recentes
    • tags
  • Computer
    • Recentes
    • tags
  • Coding
    • Recentes
    • tags
Início / coding / Perguntas / 79250789
Accepted
user2440195
user2440195
Asked: 2024-12-04 18:34:27 +0800 CST2024-12-04 18:34:27 +0800 CST 2024-12-04 18:34:27 +0800 CST

SetThreadpoolTimerEx ocasionalmente não invoca retorno de chamada

  • 772

Estou enfrentando um problema raro em que SetThreadpoolTimerEx não invoca a função de retorno de chamada conforme esperado.

Ambiente:

Sistema operacional: Windows 10 22H2 (Build 19045.5131)

Visual Studio: 2022 (Versão 17.12.0)

SDK e conjunto de ferramentas: Windows SDK 10.0.19041.0, conjunto de ferramentas de plataforma v143

Emitir:

De acordo com a documentação do SetThreadpoolTimerEx ( link ):

Se o estado anterior do temporizador foi "definido" e a função retornar FALSE, então um retorno de chamada está em andamento ou prestes a começar.

No entanto, no meu caso, a função retorna FALSE, mas o callback não está sendo chamado. Isso faz com que meu programa trave enquanto espera o callback sinalizar a conclusão.

Código C++ para reproduzir:

#include <iostream>
#include <atomic>
#include <chrono>
#include <Windows.h>

std::atomic<bool> callbackDone = false;

VOID(NTAPI callback)(
    _Inout_     PTP_CALLBACK_INSTANCE Instance,
    _Inout_opt_ PVOID                 Context,
    _Inout_     PTP_TIMER             Timer
    )
{
    printf("callback...\n");
    callbackDone = true;
}

int main() {
    bool canFail = false;

    while (true) {
        callbackDone = false;
        auto timer = CreateThreadpoolTimer(callback, nullptr, nullptr);

        LARGE_INTEGER relativeTime = {};

        relativeTime.QuadPart = 10000000 * -1;

        FILETIME relativeTimeFt = {};

        relativeTimeFt.dwLowDateTime = relativeTime.LowPart;
        relativeTimeFt.dwHighDateTime = static_cast<DWORD>(relativeTime.HighPart);

        auto setRes1 = SetThreadpoolTimerEx(timer, &relativeTimeFt, 0, 0);

        Sleep(999);

        auto setRes2 = SetThreadpoolTimerEx(timer, nullptr, 0, 0);

        if (setRes2 == TRUE) {
            FILETIME now = {};
            SetThreadpoolTimerEx(timer, &now, 0, 0);
        }
        else {
            if (!callbackDone) {
                WaitForThreadpoolTimerCallbacks(timer, FALSE);
                canFail = true;
            }
        }

        if (canFail) {
            printf("waiting for possibly failed timer\n");
        }

        auto startWaitTime = std::chrono::high_resolution_clock::now();
        auto waitMsgStep = std::chrono::seconds(10);
        auto nextMsgTime = waitMsgStep;
        while (!callbackDone) {
            SleepEx(10, TRUE);

            auto waitDuration = std::chrono::duration_cast<std::chrono::seconds>(
                std::chrono::high_resolution_clock::now() - startWaitTime
            );

            if (waitDuration > nextMsgTime) {
                printf("waiting for callback to finish for %d seconds...\n", static_cast<DWORD>(nextMsgTime.count()));
                nextMsgTime += waitMsgStep;
            }
        }

        if (canFail) {
            canFail = false;
            printf("timer is ok\n");
        }

        CloseThreadpoolTimer(timer);
    }
}

Saída possível:

insira a descrição da imagem aqui

Problema:

Apesar de SetThreadpoolTimerEx retornar FALSE — o que, de acordo com a documentação, indica que o retorno de chamada está em andamento ou prestes a começar — a função de retorno de chamada não está sendo chamada em alguns casos raros. Isso faz com que o programa fique travado indefinidamente no loop esperando que callbackDone se torne verdadeiro.

Questões:

  1. Existe algum problema conhecido com SetThreadpoolTimerEx em que o retorno de chamada pode não ser invocado mesmo que a função retorne FALSE?

  2. Estou usando incorretamente as APIs do temporizador do pool de threads de uma forma que pode causar esse comportamento?

  3. Como posso modificar meu código para garantir que o retorno de chamada seja sempre invocado ou para tratar corretamente o caso quando isso não for feito?

Além disso, do blog de Raymond Chen :

A última linha é a interessante: quando você cancela o timer ou o objeto wait, o thread pool tenta recuperar quaisquer retornos de chamada pendentes, mas às vezes um retorno de chamada já foi longe demais e não pôde ser recuperado. Por exemplo, o retorno de chamada pode já estar em andamento. Nesse caso, a função Set...Ex retorna FALSE para informar que você ainda não terminou. Você tem que esperar o retorno de chamada ser concluído antes que tudo esteja finalmente pronto.

No meu caso, SetThreadpoolTimerEx retorna FALSE, e espero 10 segundos ou mais, mas o retorno de chamada nunca é invocado.

c++
  • 1 1 respostas
  • 100 Views

1 respostas

  • Voted
  1. Best Answer
    RbMm
    2024-12-05T01:47:06+08:002024-12-05T01:47:06+08:00

    Sim, esse é um bug do Windows. Ele existe pelo menos em 23H2 22631.2861 também, onde posso reproduzi-lo.

    O código de trabalho mínimo pode ser:

    VOID NTAPI OnTimer(
                       _Inout_     PTP_CALLBACK_INSTANCE /*Instance*/,
                       _Inout_opt_ PVOID                 Context,
                       _Inout_     PTP_TIMER             /*Timer*/
                       )
    {
        *(bool*)Context = true;
    }
    
    void Test01(LONG dwMilliseconds = 1)
    {
        bool callbackDone;
    
        if (PTP_TIMER Timer = CreateThreadpoolTimer(OnTimer, &callbackDone, 0))
        {
            LARGE_INTEGER DueTime = { - (dwMilliseconds * 10000), -1 };
    
            ULONG n = 0x100;
    
            do 
            {
                callbackDone = false;
                SetThreadpoolTimerEx(Timer, (PFILETIME)&DueTime, 0, 0);
    
                Sleep(dwMilliseconds);
    
                if (!SetThreadpoolTimerEx(Timer, 0, 0, 0))
                {
                    if (!callbackDone)
                    {
                        WaitForThreadpoolTimerCallbacks(Timer, FALSE);
    
                        if (!callbackDone)
                        {
                            __debugbreak();
                            break;
                        }
                    }
                }
    
            } while (--n);
    
            CloseThreadpoolTimer(Timer);
        }
    }
    

    SetThreadpoolTimerExretorna o resultado de TppCancelTimer- então, o timer foi cancelado ou não. Se o timer foi definido antes, mas não cancelado, ele deve ser executado. E depois de uma chamada para WaitForThreadpoolTimerCallbacks, callbackDonejá deve estar definido. Mas aqui há uma condição de corrida na implementação: se chamarmos SetThreadpoolTimerEx(Timer, 0, 0, 0)quando o timer já tiver disparado, mas o retorno de chamada do usuário ainda não tiver sido chamado, digamos no TppSingleTimerExpirationponto (esta é uma função interna, não exportada), o SetThreadpoolTimerEx( TppCancelTimer) retorna falso, mas o retorno de chamada do usuário não será chamado neste caso. Podemos definir um gancho em TppSingleTimerExpiratione atrasar sua execução, para reproduzir a corrida:

    void (NTAPI *TppSingleTimerExpiration)(PTP_TIMER Timer, PSRWLOCK SRWLock, BOOLEAN b);
    
    HANDLE _G_hEvent = CreateEvent(0, 0, 0, 0);
    
    void Hook_TppSingleTimerExpiration(PTP_TIMER Timer, PSRWLOCK SRWLock, BOOLEAN b)
    {
        DbgPrint("Hook_TppSingleTimerExpiration(%p) [0]\n", Timer);
    
        SetEvent(_G_hEvent);
        Sleep(2000);
    
        DbgPrint("Hook_TppSingleTimerExpiration(%p) [1]\n", Timer);
    
        DetourTransactionBegin();
        DetourDetach((void**)&TppSingleTimerExpiration, Hook_TppSingleTimerExpiration);
        DetourTransactionCommit();
    
        TppSingleTimerExpiration(Timer, SRWLock, b);
    
        DbgPrint("Hook_TppSingleTimerExpiration(%p) [2]\n", Timer);
    }
    
    VOID NTAPI OnTimer(
                       _Inout_     PTP_CALLBACK_INSTANCE /*Instance*/,
                       _Inout_opt_ PVOID                 Context,
                       _Inout_     PTP_TIMER             /*Timer*/
                       )
    {
        *(bool*)Context = true;
    }
    
    void Test02()
    {
        if (_G_hEvent = CreateEvent(0, 0, 0, 0))
        {
            // !! need look for real address on target system
            (ULONG_PTR&)TppSingleTimerExpiration = 0x00007FFCB0FA081C;
            DetourTransactionBegin();
            DetourAttach((void**)&TppSingleTimerExpiration, Hook_TppSingleTimerExpiration);
            DetourTransactionCommit();
    
            bool callbackDone = false;
            if (PTP_TIMER Timer = CreateThreadpoolTimer(OnTimer, &callbackDone, 0))
            {
                LARGE_INTEGER DueTime = { (ULONG)-1, -1 };
                SetThreadpoolTimerEx(Timer, (PFILETIME)&DueTime, 0, 0);
    
                WaitForSingleObject(_G_hEvent, INFINITE);
    
                if (!SetThreadpoolTimerEx(Timer, 0, 0, 0))
                {
                    if (!callbackDone)
                    {
                        WaitForThreadpoolTimerCallbacks(Timer, FALSE);
    
                        if (!callbackDone)
                        {
                            __debugbreak();
                        }
    
                        Sleep(2000);
    
                        if (!callbackDone)
                        {
                            __debugbreak();
                        }
                    }
                }
    
                CloseThreadpoolTimer(Timer);
            }
    
            CloseHandle(_G_hEvent);
        }
    }
    
    • 2

relate perguntas

  • Por que os compiladores perdem a vetorização aqui?

  • Erro de compilação usando CMake com biblioteca [fechada]

  • Erro lançado toda vez que tento executar o premake

  • Como criar um tipo de octeto semelhante a std::byte em C++?

  • Somente operações bit a bit para std::byte em C++ 17?

Sidebar

Stats

  • Perguntas 205573
  • respostas 270741
  • best respostas 135370
  • utilizador 68524
  • Highest score
  • respostas
  • Marko Smith

    Vue 3: Erro na criação "Identificador esperado, mas encontrado 'import'" [duplicado]

    • 1 respostas
  • Marko Smith

    Por que esse código Java simples e pequeno roda 30x mais rápido em todas as JVMs Graal, mas não em nenhuma JVM Oracle?

    • 1 respostas
  • Marko Smith

    Qual é o propósito de `enum class` com um tipo subjacente especificado, mas sem enumeradores?

    • 1 respostas
  • Marko Smith

    Como faço para corrigir um erro MODULE_NOT_FOUND para um módulo que não importei manualmente?

    • 6 respostas
  • Marko Smith

    `(expression, lvalue) = rvalue` é uma atribuição válida em C ou C++? Por que alguns compiladores aceitam/rejeitam isso?

    • 3 respostas
  • Marko Smith

    Quando devo usar um std::inplace_vector em vez de um std::vector?

    • 3 respostas
  • Marko Smith

    Um programa vazio que não faz nada em C++ precisa de um heap de 204 KB, mas não em C

    • 1 respostas
  • Marko Smith

    PowerBI atualmente quebrado com BigQuery: problema de driver Simba com atualização do Windows

    • 2 respostas
  • Marko Smith

    AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos

    • 1 respostas
  • Marko Smith

    Estou tentando fazer o jogo pacman usando apenas o módulo Turtle Random e Math

    • 1 respostas
  • Martin Hope
    Aleksandr Dubinsky Por que a correspondência de padrões com o switch no InetAddress falha com 'não cobre todos os valores de entrada possíveis'? 2024-12-23 06:56:21 +0800 CST
  • Martin Hope
    Phillip Borge Por que esse código Java simples e pequeno roda 30x mais rápido em todas as JVMs Graal, mas não em nenhuma JVM Oracle? 2024-12-12 20:46:46 +0800 CST
  • Martin Hope
    Oodini Qual é o propósito de `enum class` com um tipo subjacente especificado, mas sem enumeradores? 2024-12-12 06:27:11 +0800 CST
  • Martin Hope
    sleeptightAnsiC `(expression, lvalue) = rvalue` é uma atribuição válida em C ou C++? Por que alguns compiladores aceitam/rejeitam isso? 2024-11-09 07:18:53 +0800 CST
  • Martin Hope
    The Mad Gamer Quando devo usar um std::inplace_vector em vez de um std::vector? 2024-10-29 23:01:00 +0800 CST
  • Martin Hope
    Chad Feller O ponto e vírgula agora é opcional em condicionais bash com [[ .. ]] na versão 5.2? 2024-10-21 05:50:33 +0800 CST
  • Martin Hope
    Wrench Por que um traço duplo (--) faz com que esta cláusula MariaDB seja avaliada como verdadeira? 2024-05-05 13:37:20 +0800 CST
  • Martin Hope
    Waket Zheng Por que `dict(id=1, **{'id': 2})` às vezes gera `KeyError: 'id'` em vez de um TypeError? 2024-05-04 14:19:19 +0800 CST
  • Martin Hope
    user924 AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos 2024-03-20 03:12:31 +0800 CST
  • Martin Hope
    MarkB Por que o GCC gera código que executa condicionalmente uma implementação SIMD? 2024-02-17 06:17:14 +0800 CST

Hot tag

python javascript c++ c# java typescript sql reactjs html

Explore

  • Início
  • Perguntas
    • Recentes
    • Highest score
  • tag
  • help

Footer

AskOverflow.Dev

About Us

  • About Us
  • Contact Us

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve