Задачи на таймер

1) Напишите функцию - троттлер trottle(f,ms), которая передает вызов в функцию f не более 1 раза в ms милисекунд, те вызовы, которые препадают на интервал простоя - должны игнорироваться. Напишите программу для демонстрации работы функции trottle.

package main

import (
	"fmt"
	"time"
)

// throttle принимает функцию f и интервал времени ms (в миллисекундах).
// Возвращает функцию, которую можно вызывать с той же частотой,
// но f будет выполняться не чаще одного раза в указанный интервал.
func throttle(f func(), ms int) func() {
	timer := time.NewTimer(0) // Создаем таймер с нулевой длительностью для немедленного первого вызова
	<-timer.C                 // Сразу же освобождаем таймер
	throttled := false        // Флаг, указывающий, активен ли таймер

	return func() {
		if !throttled {
			throttled = true
			f() // Вызываем функцию f
			timer.Reset(time.Duration(ms) * time.Millisecond)
			go func() {
				<-timer.C
				throttled = false
			}()
		}
	}
}

func main() {
	count := 0
	increment := func() {
		count++
		fmt.Println("Incremented:", count)
	}

	throttledIncrement := throttle(increment, 1000) // Создаем троттлированную версию функции increment

	// Пытаемся вызвать функцию несколько раз с интервалом в 300 мс
	for i := 0; i < 10; i++ {
		throttledIncrement()
		fmt.Println("Try:", i)
		time.Sleep(300 * time.Millisecond)
	}

	// Даем время для последнего вызова
	time.Sleep(1500 * time.Millisecond)
	fmt.Println("Final count:", count)
}

Объяснение:

1. Функция `throttle` принимает целевую функцию `f` и интервал `ms`. Она возвращает новую функцию, которая при вызове проверяет, активен ли таймер. Если таймер не активен, функция `f` вызывается, и таймер устанавливается на заданный интервал.

2. Внутри возвращаемой функции используется горутина для асинхронного ожидания окончания таймера. Как только таймер срабатывает, флаг `throttled` сбрасывается, позволяя следующему вызову функции выполнить `f` снова.

3. В функции `main` создается функция `increment`, которая увеличивает счетчик и выводит его значение. Затем создается троттлированная версия этой функции с интервалом в 1000 мс (1 секунда).

4. Цикл в `main` пытается вызвать `throttledIncrement` каждые 300 мс, но из-за троттлинга большинство вызовов игнорируются, и функция `increment` выполняется не чаще одного раза в секунду.

Этот подход позволяет контролировать частоту выполнения функции, предотвращая ее чрезмерный вызов и возможное перегружение ресурсов.

Last updated