using System;
using System.Threading;
using System.Windows.Forms;
using UtilForm.Util;
namespace UtilForm
{
    // 線程同步，事件觸發(fā)，信號量，互斥鎖，共享內(nèi)存，消息隊列
    public partial class frmUIThread : Form
    { 
        SynchronizationContext context;// 子線程同步到主線程 
        public delegate void DoSth(object sender); // 事件觸發(fā)
        public event DoSth OnMyEvent;
        Mutex mutex = new Mutex(); // 互斥鎖，鎖住某一資源 
        ManualResetEvent manualReset = new ManualResetEvent(false); // 信號量，流程上鎖定,A執(zhí)行完再執(zhí)行B  
        public frmUIThread()
        {
            InitializeComponent();
        }
        private void MainForm_Load(object sender, EventArgs e)
        { 
            context = SynchronizationContext.Current; 
            OnMyEvent += new DoSth(ProgressEvent);
            Console.WriteLine("主線程id：" + Thread.CurrentThread.ManagedThreadId);
            // 線程同步
            ThreadPool.QueueUserWorkItem(state =>
            {
                Console.WriteLine("子線程id：" + Thread.CurrentThread.ManagedThreadId);
                for (int i = 0; i < 3; ++i)
                {
                    //textBox1.Text = i.ToString();//:“線程間操作無效: 從不是創(chuàng)建控件“textBox1”的線程訪問它?！?
                    //
                    // 寫法1：
                    //textBox1.BeginInvoke((MethodInvoker)delegate
                    //{
                    //    textBox1.Text = i.ToString();
                    //});
                    //
                    //
                    // 寫法2：
                    context.Send(ProgressUI, i);
                    if (2 == i)
                    {
                        OnMyEvent(i);// 線程間回調(diào)
                    }
                    Thread.Sleep(100);
                }
            });
            // 模擬互斥量
            ThreadPool.QueueUserWorkItem(new WaitCallback(ThdMutex));
            ThreadPool.QueueUserWorkItem(new WaitCallback(ThdMutex));
            // 模擬信號量在B流程中阻塞，A流程結(jié)束，繼續(xù)B流程
            ThreadPool.QueueUserWorkItem(state =>
            {
                Console.WriteLine("模擬信號量，A開始執(zhí)行");
                Thread.Sleep(5000);
                manualReset.Set();// 釋放
                Console.WriteLine("模擬信號量，A執(zhí)行完成");
            });
            ThreadPool.QueueUserWorkItem(state =>
            {
                Console.WriteLine("模擬信號量，B等待執(zhí)行");
                manualReset.Reset();// 重置信號量 
                manualReset.WaitOne();// 停止
                //manualReset.WaitOne(2000);// 帶超時停止
                Console.WriteLine("模擬信號量，B執(zhí)行完成");
            }); 
            // 共享內(nèi)存 
            ThreadPool.QueueUserWorkItem(state =>
            {
                MemoryCacheHelper.SetCache("10001", "123");
            });
            ThreadPool.QueueUserWorkItem(state =>
            {
                Thread.Sleep(5000);
                var val = MemoryCacheHelper.GetCache("10001");
                Console.WriteLine($"共享內(nèi)存：{val}");
            });
        }
        /// <summary>
        /// 更新UI
        /// </summary>
        /// <param name="obj"></param>
        private void ProgressUI(object obj)
        {
            Console.WriteLine("更新UI線程::當前線程id：" + Thread.CurrentThread.ManagedThreadId);
            textBox1.Text = obj.ToString();
        }
        /// <summary>
        /// 事件處理
        /// </summary>
        private void ProgressEvent(object sender)
        {
            Console.WriteLine($"線程事件觸發(fā):{sender.ToString()}");
        }
        void ThdMutex(object obj)
        {
            mutex.WaitOne();
            Console.WriteLine($"互斥線程 {Thread.CurrentThread.ManagedThreadId} 正在執(zhí)行任務(wù)");
            Thread.Sleep(1000);
            Console.WriteLine($"互斥線程 {Thread.CurrentThread.ManagedThreadId} 任務(wù)執(zhí)行完畢");
            mutex.ReleaseMutex(); 
        }
    }
}

using System;
using System.Runtime.Caching;
namespace UtilForm.Util
{
    public class MemoryCacheHelper
    {
        private static MemoryCache cache = MemoryCache.Default;// MemoryCache ObjectCache
        /// <summary>
        /// 讀取緩存
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        public static object GetCache(string key)
        {
            var obj = cache.Get(key);
            //Console.WriteLine($"-讀取緩存[{key}]:{JsonConvert.SerializeObject(obj, Formatting.Indented)}");
            return obj;
        }
        /// <summary>
        /// 寫入緩存
        /// </summary>
        /// <param name="key"></param>
        /// <param name="obj"></param>
        /// <param name="timeout">過期時間,默認7200秒</param>
        public static void SetCache(string key, object obj, int timeout = 7200)
        {
            cache.Set(key, obj, DateTimeOffset.Now.AddSeconds(timeout));
            //Console.WriteLine($"-寫入緩存[{key}]:{JsonConvert.SerializeObject(obj, Formatting.Indented)}");
        }
        /// <summary>
        /// 刪除緩存
        /// </summary>
        /// <param name="key"></param>
        public static void RemoveCache(string key)
        {
            cache.Remove(key);
            //Console.WriteLine($"-移除緩存[{key}]");
        }
    }
}