Параллельная обработка коллекции через Parallel.ForEach!

Когда нужно быстро выполнить CPU-интенсивную работу над большим набором данных, можно распараллелить обработку без сложной ручной работы с потоками:

// Исходная коллекция—скажем, список чисел
var numbers = new int[1_000_000];
new Random().NextBytes(new Span<byte>(new byte[0])); // просто для примера
for (int i = 0; i < numbers.Length; i++)
    numbers[i] = i;

Вызовем Parallel.ForEach, соберём результаты в потокобезопасную коллекцию и зададим максимальное число параллельных задач:

var results = new ConcurrentBag<int>();
var options = new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount };

Parallel.ForEach(numbers, options, number =>
{
    // эмуляция тяжёлой работы
    int squared = number * number;
    results.Add(squared);
});

ConcurrentBag<T> гарантирует, что в него можно безопасно записывать из разных потоков без блокировок:

Console.WriteLine($"Обработано элементов: {results.Count}");
Console.WriteLine($"Первый результат: {results.Min()} | Последний: {results.Max()}");

🔥 Совет: поэкспериментируйте с MaxDegreeOfParallelism — на некоторых задачах меньшее число потоков даёт лучшее быстродействие за счёт меньшего оверхеда переключений.

➡️ C# Ready | #практика

Отслеживаем изменения в папке через FileSystemWatcher — мгновенный отклик без опроса!

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

Сначала задаём путь и настраиваем watcher: реагируем на создание и изменение только .txt-файлов, подписываемся на события Created и Changed:

using System.IO;

string path = @"C:\Watched";
using var watcher = new FileSystemWatcher(path, "*.txt")
{
    NotifyFilter = NotifyFilters.FileName | NotifyFilters.LastWrite,
    IncludeSubdirectories = false, 
// или true — если нужны подпапки
    EnableRaisingEvents = true     
// запускаем слежение
};

watcher.Created += OnChanged;
watcher.Changed += OnChanged;

Обработчик получает данные об изменении и выводит краткую информацию:

static void OnChanged(object sender, FileSystemEventArgs e)
{
    Console.WriteLine($"[{DateTime.Now:HH:mm:ss}] {e.ChangeType}: {e.FullPath}");
}

Чтобы консольное приложение не завершилось раньше времени, просто ждём клавишу:

Console.WriteLine($"👀 Слежение за {path} запущено. Нажмите Enter для выхода…");
Console.ReadLine();

🔥 FileSystemWatcher избавляет от циклов опроса: оперативно, без лишних ресурсов и под любые типы файлов.

➡️ C# Ready | #практика

Горячая перезагрузка конфигурации через IOptionsMonitor — мгновенные изменения без рестарта!

Иногда DevOps-ам нужно править лимиты или строки подключения прямо в appsettings.json, а пользователям нельзя прерывать сервис. Подключаем «живую» конфигурацию и реагируем на правки на лету.

Подготавливаем конфиг с reloadOnChange и DI-контейнер:

var config = new ConfigurationBuilder()
    .AddJsonFile("appsettings.json", reloadOnChange: true)
    .Build();

var services = new ServiceCollection()
    .AddSingleton<IConfiguration>(config)
    .Configure<MySettings>(config.GetSection("MySettings"))
    .AddSingleton<Worker>()
    .BuildServiceProvider();

// запускаем
services.GetRequiredService<Worker>();     
Console.ReadLine();                       

Регистрируем класс настроек и ловим изменения:

public record MySettings(int Limit, string Message);

public class Worker
{
    public Worker(IOptionsMonitor<MySettings> opts) =>
        opts.OnChange(s =>
            Console.WriteLine($"↻ Новый лимит: {s.Limit}, msg: {s.Message}")
        );
}

🔥 Правьте appsettings.json — консоль сразу выводит новые значения: без перезапуска, без таймеров, полностью нативно.

➡️ C# Ready | #практика