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 / 79553997
Accepted
Caleb Keller
Caleb Keller
Asked: 2025-04-04 04:57:17 +0800 CST2025-04-04 04:57:17 +0800 CST 2025-04-04 04:57:17 +0800 CST

Como pausar a execução do método até que pelo menos N segundos tenham passado desde a última alteração em um diretório?

  • 772

Tenho um processo que precisa mover intermitentemente alguns arquivos de um diretório para outro. Antes de mover os arquivos, preciso garantir que um usuário não esteja adicionando arquivos ao diretório no momento - se estiver, quero esperar até que nenhum arquivo novo tenha sido adicionado ao diretório por N segundos antes de continuar o processo (o valor de N realmente não importa aqui).

Minha ideia original era usar um FileSystemWatcherpara capturar eventos de criação de arquivo, usar o .Throttle()método de Rx para obter o último evento gerado dentro do período de tempo especificado e usar o resultado disso para desabilitar um loop de atraso infinito. O problema é que esse método apenas esperará para sempre se um usuário nunca fizer nenhuma alteração no diretório. De alguma forma, preciso que isso espere pelo menos N segundos e, se não houver nenhuma alteração dentro desse período de tempo, continue. Se houver uma alteração dentro desse período de tempo, espere até que N segundos tenham se passado desde a última alteração.

Aqui está o que tenho até agora:

Console.WriteLine("start");

// wait to ensure no changes are being made to the directory
await Task.Run(async () =>
{
    var watcher = new FileSystemWatcher("D:\\Users\\mwcjk1\\source\\repos\\RandomTestAppNet8\\RandomTestAppNet8\\");
    watcher.EnableRaisingEvents = true;

    watcher.Created += (o, a) => { Console.WriteLine("file changed!"); };

    var subject = Observable.FromEventPattern<FileSystemEventHandler, FileSystemEventArgs>(
        ev => watcher.Created += ev,
        ev => watcher.Created -= ev
        );

    bool done = false;

    // wait for 7 seconds after the last file creation
    var disposable = subject.Throttle(TimeSpan.FromSeconds(7)).Subscribe(events => { done = true; });

    Console.WriteLine("Set up observer");

    while (!done)
    {
        await Task.Delay(1000);
        //Console.WriteLine("Waited 1 sec");
    }

    disposable.Dispose();
});

// Continue with the rest of the method execution
Console.WriteLine("done!");

Eu também não gosto do Task.Delay()loop - parece que deveria haver uma maneira muito mais elegante de fazer isso ( .Throttle()parece tão perto de funcionar sozinho!), mas não consegui descobrir.

Qualquer conselho é muito apreciado, obrigado!

c#
  • 5 5 respostas
  • 74 Views

5 respostas

  • Voted
  1. Best Answer
    Zdeněk Jelínek
    2025-04-04T17:56:59+08:002025-04-04T17:56:59+08:00

    Primeiramente, para isso:

    Eu também não gosto do loop Task.Delay() - parece que deveria haver uma maneira muito mais elegante de fazer isso

    Um TaskCompletionSource é um adaptador de eventos/mundo reativo para Taskmundo. Basicamente, ele expõe um Taskque pode ser concluído, com falha ou cancelado chamando métodos na fonte de conclusão.

    Você pode reescrever seu código com Task.Delayisto:

        var completion = new TaskCompletionSource();
    
        // wait for 7 seconds after the last file creation
        var disposable = subject.Throttle(TimeSpan.FromSeconds(7)).Subscribe(_ => completion.TrySetResult());
    
        Console.WriteLine("Set up observer");
    
        await completion.Task; // Will wait until Throttle/Subscribe is called
    
        disposable.Dispose();
    

    Em segundo lugar, você também menciona

    O problema é que esse método esperará para sempre se o usuário não fizer nenhuma alteração no diretório.

    Isso ocorre porque você está esperando o evento disparar, mas ele não será disparado até que alterações sejam feitas no diretório.

    O que eu sugeriria em vez disso é verificar se o diretório teve alguma alteração recentemente e, se tiver, esperar um pouco e tentar novamente. Por exemplo:

    while (!shutdownToken.IsCancellationRequested) // Your main driving loop, not sure what that is
    {
        if (HasAnyRecentChanges(theDirectoryOfInterest))
        {
            await Task.Delay(debounceTime /* N in your question */, shutdownToken);
            continue;
        }
    
        ProcessFiles(theDirectoryOfInterest);
        await WaitUntilItsTimeToRunTheMainLoopAgainAsync(shutdownToken);
    }
    

    Agora a questão é como HasAnyRecentChangesserá a implementação. Eu sugiro usar a coisa mais simples possível para começar - apenas verificar os últimos horários de modificação dos arquivos no diretório.

    Isso pode ser lento para um grande número de arquivos, portanto, usar FileSystemWatchere manter o horário da última modificação em um campo pode ser uma otimização, especialmente se você executar isso com muita frequência ou para um pequeno N. No entanto, carregar os horários da última modificação de todos os arquivos ainda seria necessário para inicializar o campo na inicialização, de modo que essa implementação será necessária em ambos os casos.

    Desculpe pela falta de receita, acho que não conseguiria deixar o produto mais limpo com ela.

    • 1
  2. JonasH
    2025-04-04T20:16:01+08:002025-04-04T20:16:01+08:00

    Uma abordagem possível é usar um timer que é reiniciado sempre que o usuário faz uma alteração. Algo como:

    public class MyClass
    {
        private readonly TimeSpan delay;
        private System.Threading.Timer timer;
        private ManualResetEventSlim resetEvent = new(true);
    
        public MyClass(TimeSpan delay)
        {
            this.delay = delay;
            timer = new Timer(MyDelayedMethod, null, Timeout.InfiniteTimeSpan, Timeout.InfiniteTimeSpan);
        }
    
        public void OnFileSystemEvent()
        {
            resetEvent.Reset();
            timer.Change(delay, Timeout.InfiniteTimeSpan);
        }
    
        private void MyDelayedMethod(object _) => resetEvent.Set();
        public void WaitForQuietPeriod() => resetEvent.Wait();
    }
    

    Este é um código de nível bem baixo, usando código de bloqueio em vez de algo assíncrono, mas ainda é bem direto. Se você precisar de código assíncrono, provavelmente poderá substituir o resetEvent por uma fonte TaskCompletion. Fazer a chamada FileSystemWatcher OnFileSystemEventé deixado como um exercício.

    Você provavelmente quer fazer deste um objeto de longa duração, para que ele possa monitorar alterações mesmo quando você não estiver copiando nenhum arquivo. Como alternativa, verifique a data de modificação em qualquer arquivo na inicialização e inicialize o evento de redefinição como falso se qualquer arquivo tiver sido modificado dentro do tempo de atraso, bem como inicialize o timer com o tempo de vencimento restante.

    • 1
  3. Neralem
    2025-04-04T15:03:05+08:002025-04-04T15:03:05+08:00

    Talvez você queira procurar o termo "debouncer". Aqui está uma implementação simples que eu não testei:
    https://gist.github.com/lcnvdl/43bfdcb781d799df6b7e8e66fe3792db

    Mas parece bom para mim.

    Basta chamar Debounce() toda vez que algo mudar no seu diretório e passar seu método que copiará os arquivos.

    • 0
  4. Oleg Dok
    2025-04-04T15:12:03+08:002025-04-04T15:12:03+08:00

    Tente isto, input - é a fonte dos eventos do observador do seu sistema de arquivos:

    public static IObservable<Unit> EmitOnTimeout<T>(this IObservable<T> input, TimeSpan expirationTimeout)
    {
        var postponerSink = new Subject<T>();
        var emitter = postponerSink
        .Synchronize()
        .StartWith(default(T))
        .Select(_ => Observable.Return(Unit.Default).DelaySubscription(expirationTimeout))
        .Switch();
    
        return  Observable.Using(() => new CompositeDisposable(input.Subscribe(postponerSink), postponerSink), _ => emitter);
    }
    
    • 0
  5. Caleb Keller
    2025-04-05T05:48:12+08:002025-04-05T05:48:12+08:00

    Vale a pena mencionar que aqui está a implementação que fiz depois de receber sugestões de algumas outras respostas/comentários:

    private async Task WaitOnDirectoryChanges(string directory, int timeoutMillis)
    {
        int delayTime = timeoutMillis;
    
        while (true)
        {
            await Task.Delay(delayTime);
            _cancellationToken.ThrowIfCancellationRequested();
    
            var lastWrite = Directory.GetLastWriteTimeUtc(directory);
            var lastWriteMillisecondsAgo = (int)Math.Round((DateTime.UtcNow - lastWrite).TotalMilliseconds);
    
            if (lastWriteMillisecondsAgo <= delayTime)
            {
                delayTime = timeoutMillis - lastWriteMillisecondsAgo;
                _logger.Debug("Detected changes in {directory} within the timeout period of {timeoutMillis}ms. Waiting {delayTime}ms for further changes.", directory, timeoutMillis, delayTime);
            }
            else
            {
                break;
            }
        }
    }
    
    • 0

relate perguntas

  • Polly DecorrelatedJitterBackoffV2 - como calcular o tempo máximo necessário para concluir todas as novas tentativas?

  • Wpf. Role o DataGrid dentro do ScrollViewer

  • A pontuação que ganhei na página do jogo com .NET MAUI MVVM não é visível em outras páginas. Como posso manter os dados de pontuação no dispositivo local

  • Use a hierarquia TreeView com HierarchicalDataTemplate de dentro de um DataTemplate

  • Como posso melhorar essa interface de validação no .NET?

Sidebar

Stats

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

    Reformatar números, inserindo separadores em posições fixas

    • 6 respostas
  • Marko Smith

    Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não?

    • 2 respostas
  • Marko Smith

    Problema com extensão desinstalada automaticamente do VScode (tema Material)

    • 2 respostas
  • Marko Smith

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

    • 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

    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
  • Martin Hope
    Fantastic Mr Fox Somente o tipo copiável não é aceito na implementação std::vector do MSVC 2025-04-23 06:40:49 +0800 CST
  • Martin Hope
    Howard Hinnant Encontre o próximo dia da semana usando o cronógrafo 2025-04-21 08:30:25 +0800 CST
  • Martin Hope
    Fedor O inicializador de membro do construtor pode incluir a inicialização de outro membro? 2025-04-15 01:01:44 +0800 CST
  • Martin Hope
    Petr Filipský Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não? 2025-03-23 21:39:40 +0800 CST
  • Martin Hope
    Catskul O C++20 mudou para permitir a conversão de `type(&)[N]` de matriz de limites conhecidos para `type(&)[]` de matriz de limites desconhecidos? 2025-03-04 06:57:53 +0800 CST
  • Martin Hope
    Stefan Pochmann Como/por que {2,3,10} e {x,3,10} com x=2 são ordenados de forma diferente? 2025-01-13 23:24:07 +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

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