C# 多线程并发编程基础小结

Thread thread = new Thread(new ThreadStart(YourMethod));

thread.Start();

object lockObject = new object();
lock (lockObject)
{
    // 临界区代码
}

Mutex mutex = new Mutex();
mutex.WaitOne();
// 临界区代码
mutex.ReleaseMutex();

Semaphore semaphore = new Semaphore(1, 1);
semaphore.WaitOne();
// 临界区代码
semaphore.Release();

ManualResetEvent event = new ManualResetEvent(false);
event.Set(); // 通知其他线程
event.WaitOne(); // 等待其他线程通知

AutoResetEvent waitHandle = new AutoResetEvent(false);
waitHandle.Set(); // 通知其他线程
waitHandle.WaitOne(); // 等待其他线程通知

ThreadPool.QueueUserWorkItem(new WaitCallback(YourMethod));

public async Task<int> YourAsyncMethod()
{
    // 异步操作
    var result = await SomeAsyncOperation();
    return result;
}

Task task = new Task(YourMethod);
task.Start();

Task.WaitAll(task1, task2);

Parallel.For(0, 100, i => 
{
    // 并行执行的代码
});

var query = from num in numbers.AsParallel()
           where num % 2 == 0
           select num;

SynchronizationContext context = SynchronizationContext.Current;

context.Post(state => 
{
    // 在正确的线程上执行的代码
}, state);

ConcurrentDictionary<int, string> dict = new ConcurrentDictionary<int, string>();
dict.TryAdd(1, "Value1");
string value;
dict.TryGetValue(1, out value);

ConcurrentQueue<int> queue = new ConcurrentQueue<int>();
queue.Enqueue(1);
int item;
queue.TryDequeue(out item);

ImmutableList<int> list = ImmutableList.Create(1, 2, 3);

PerformanceCounter counter = new PerformanceCounter("Category", "Counter");
counter.NextValue();

using (var writer = new StreamWriter("log.txt", true))
{
    writer.WriteLine("Thread {0} is executing.", Thread.CurrentThread.ManagedThreadId);
}