// 矩陣乘法加速（使用 SIMD 指令）
void MultiplyMatrices(float[,] matA, float[,] matB, float[,] result)
{
    int size = matA.GetLength(0);
    
    // 使用硬并行度 (物理核心數(shù))
    var parallelOptions = new ParallelOptions 
    { 
        MaxDegreeOfParallelism = Environment.ProcessorCount 
    };
    
    Parallel.For(0, size, parallelOptions, i => 
    {
        for (int j = 0; j < size; j++)
        {
            Vector<float> sum = Vector<float>.Zero;
            for (int k = 0; k < size; k += Vector<float>.Count)
            {
                Vector<float> aVec = new Vector<float>(matA, i, k);
                Vector<float> bVec = new Vector<float>(matB, k, j);
                sum += aVec * bVec;  // SIMD 并行計(jì)算
            }
            result[i, j] = Vector.Dot(sum, Vector<float>.One);
        }
    });
}

// 多源數(shù)據(jù)聚合計(jì)算
async Task ProcessMultiSourceAsync()
{
    var source1Task = FetchDataFromAPI("https://source1.com");
    var source2Task = LoadDatabaseDataAsync("DataSource=...");
    var source3Task = ReadLocalFileAsync("data.json");
    
    // 并行等待所有任務(wù)
    await Task.WhenAll(source1Task, source2Task, source3Task);
    
    // 安全合并結(jié)果（避免鎖機(jī)制）
    var results = new [] { 
        source1Task.Result, 
        source2Task.Result, 
        source3Task.Result 
    };
    
    var finalResult = CombineData(results);
}

// 高性能并發(fā)通道
async Task RunConcurrentPipelineAsync()
{
    // 優(yōu)化選項(xiàng)：減少內(nèi)存分配
    var options = new UnboundedChannelOptions
    {
        AllowSynchronousContinuations = false,
        SingleReader = false,  // 支持多消費(fèi)者
        SingleWriter = false   // 支持多生產(chǎn)者
    };
    
    var channel = Channel.CreateUnbounded<DataItem>(options);
    var producerTasks = new List<Task>();
    
    // 啟動(dòng) 3 個(gè)生產(chǎn)者
    for (int i = 0; i < 3; i++)
    {
        producerTasks.Add(ProduceItemsAsync(channel.Writer));
    }
    
    // 啟動(dòng) 4 個(gè)消費(fèi)者
    var consumerTasks = Enumerable.Range(1, 4)
        .Select(_ => ConsumeItemsAsync(channel.Reader))
        .ToArray();
    
    // 等待生產(chǎn)完成
    await Task.WhenAll(producerTasks);
    channel.Writer.Complete();
    
    // 等待消費(fèi)完成
    await Task.WhenAll(consumerTasks);
}

// 分頁(yè)數(shù)據(jù)的并發(fā)批處理 (.NET 6+)
async Task BatchProcessAsync(IEnumerable<int> allItems)
{
    // 使用 Parallel.ForEachAsync 限流
    await Parallel.ForEachAsync(
        source: allItems,
        parallelOptions: new ParallelOptions 
        { 
            MaxDegreeOfParallelism = 10,  // 限制并發(fā)度
            CancellationToken = _cts.Token
        },
        async (item, ct) => 
        {
            await using var semaphore = new SemaphoreSlimDisposable(5); // 細(xì)粒度控制
            await semaphore.WaitAsync(ct);
            try
            {
                await ProcessItemAsync(item, ct);
            }
            finally
            {
                semaphore.Release();
            }
        });
}
 
// 自動(dòng)釋放的信號(hào)量包裝器
struct SemaphoreSlimDisposable : IAsyncDisposable
{
    private readonly SemaphoreSlim _semaphore;
    public SemaphoreSlimDisposable(int count) => _semaphore = new SemaphoreSlim(count);
    public ValueTask WaitAsync(CancellationToken ct) => _semaphore.WaitAsync(ct).AsValueTask();
    public void Release() => _semaphore.Release();
    public ValueTask DisposeAsync() => _semaphore.DisposeAsync();
}

// 避免偽共享（False Sharing）
class FalseSharingSolution
{
    [StructLayout(LayoutKind.Explicit, Size = 128)]
    struct PaddedCounter
    {
        [FieldOffset(64)] // 每個(gè)計(jì)數(shù)器獨(dú)占緩存行
        public long Counter;
    }
    
    private readonly PaddedCounter[] _counters = new PaddedCounter[4];
    
    public void Increment(int index) => Interlocked.Increment(ref _counters[index].Counter);
}

// 為高優(yōu)先級(jí)任務(wù)創(chuàng)建專(zhuān)用線程池
static TaskFactory HighPriorityTaskFactory
{
    get
    {
        var threadCount = Environment.ProcessorCount / 2;
        var threads = new Thread[threadCount];
        
        for (int i = 0; i < threadCount; i++)
        {
            var t = new Thread(() => Thread.CurrentThread.Priority = ThreadPriority.Highest)
            {
                IsBackground = true,
                Priority = ThreadPriority.Highest
            };
            threads[i] = t;
        }
        
        var taskScheduler = new ConcurrentExclusiveSchedulerPair(
            TaskScheduler.Default, threadCount).ConcurrentScheduler;
            
        return new TaskFactory(CancellationToken.None, 
            TaskCreationOptions.DenyChildAttach,
            TaskContinuationOptions.None,
            taskScheduler);
    }
}
 
// 使用示例
HighPriorityTaskFactory.StartNew(() => ExecuteCriticalTask());

// 使用 ConcurrencyVisualizer
async Task TrackParallelism()
{
    using (var listener = new ConcurrencyVisualizerTelemetry())
    {
        // 標(biāo)記并行區(qū)域
        listener.BeginOperation("Parallel_Core");
        await ProcessBatchParallelAsync();
        listener.EndOperation("Parallel_Core");
        
        // 標(biāo)記串行區(qū)域
        listener.BeginOperation("Sync_Operation");
        RunSyncCalculation();
        listener.EndOperation("Sync_Operation");
    }
}

# 查看線程池使用情況
dotnet-counters monitor -p PID System.Threading.ThreadPool
 
# 檢測(cè)鎖競(jìng)爭(zhēng)
dotnet-dump collect --type Hang -p PID