Python, усеченный после сотни?

Это не тривиальный запрос на код с нуля, поскольку есть несколько нюансов. Аналогичный сценарий отслеживает FileSystemWatcher и ожидает, пока что-то успокоится после большой копии, прежде чем пытаться открыть измененные файлы.

Реактивные расширения в .NET 4.5 были созданы для обработки именно этих сценариев. Вы можете легко использовать их для обеспечения такой функциональности с помощью таких методов, как Throttle , Buffer , Window или Sample . Вы публикуете события в субъекте , применяете к нему одну из оконных функций, например, чтобы получать уведомление, только если не было активности в течение X секунд или событий Y, а затем подписываетесь на уведомление.

Subject _mySubject=new Subject();
....
var eventSequenc=mySubject.Throttle(TimeSpan.FromSeconds(1))
                          .Subscribe(events=>MySubscriptionMethod(events));

Дроссель возвращает последнее событие в скользящем окне, только если в окне не было других событий. Любое событие сбрасывает окно.

Вы можете найти очень хороший обзор сдвинутых во времени функций здесь

Когда ваш код получает событие, вам нужно только опубликовать его в теме с помощью OnNext:

_mySubject.OnNext(MyEventData);

Если ваше аппаратное событие выглядит как типичное событие .NET, вы можете обойти тему и ручную публикацию с помощью Observable.FromEventPattern , как показано здесь :

var mySequence = Observable.FromEventPattern(
    h => _myDevice.MyEvent += h,
    h => _myDevice.MyEvent -= h);  
_mySequence.Throttle(TimeSpan.FromSeconds(1))
           .Subscribe(events=>MySubscriptionMethod(events));

Вы также можете создавать наблюдаемые из задач, комбинировать последовательности событий с операторами LINQ для запроса, например: пары различных аппаратных событий с Zip, использовать другой источник событий для привязки Throttle / Buffer и т. Д., Добавлять задержки и многое другое . [+1122]

Reactive Extensions доступны в виде пакета NuGet , поэтому их очень легко добавить в ваш проект.

Книга Стивена Клири « Параллелизм в C # Cookbook » является очень хорошим ресурсом по Reactive Extensions и объясняет, как вы можете использовать его и как он сочетается с остальными параллельных API в .NET, таких как Tasks, Events и т. д.

Введение в Rx - превосходная серия статей (здесь я скопировал примеры) с несколькими примерами.

ОБНОВЛЕНИЕ

Используя ваш конкретный пример, вы можете сделать что-то вроде:

IObservable _myObservable;

private MachineClass connect()
{

    MachineClass rpc = new MachineClass();
   _myObservable=Observable
                 .FromEventPattern(
                            h=> rpc.RxVARxH += h,
                            h=> rpc.RxVARxH -= h)
                 .Throttle(TimeSpan.FromSeconds(1));
   _myObservable.Subscribe(machine=>eventRxVARxH(machine));
    return rpc;
}

Конечно, это может быть значительно улучшено - как наблюдаемое, так и подписка должны быть расположены в какой-то момент. Этот код предполагает, что вы управляете только одним устройством. Если у вас много устройств, вы можете создать наблюдаемое внутри класса, чтобы каждый MachineClass выставлял и располагал свою собственную наблюдаемую.