namespace Test
{
  class Program
  {
    static void Main(string[] args)
    {
      Thread t1 = new Thread(new ThreadStart(TestMethod));
      Thread t2 = new Thread(new ParameterizedThreadStart(TestMethod));
      t1.IsBackground = true;
      t2.IsBackground = true;
      t1.Start();
      t2.Start("hello");
      Console.ReadKey();
    }

    public static void TestMethod()
    {
      Console.WriteLine("不帶參數(shù)的線程函數(shù)");
    }

    public static void TestMethod(object data)
    {
      string datastr = data as string;
      Console.WriteLine("帶參數(shù)的線程函數(shù)，參數(shù)為：{0}", datastr);
    }
  } 
}

class Program
  {
    static void Main(string[] args)
    {
      //將工作項(xiàng)加入到線程池隊(duì)列中，這里可以傳遞一個(gè)線程參數(shù)
      ThreadPool.QueueUserWorkItem(TestMethod, "Hello");
      Console.ReadKey();
    }

    public static void TestMethod(object data)
    {
      string datastr = data as string;
      Console.WriteLine(datastr);
    }
  }

class Program
  {
    static void Main(string[] args)
    {
      Task<Int32> t = new Task<Int32>(n => Sum((Int32)n), 1000);
      t.Start();
      t.Wait();
      Console.WriteLine(t.Result);
      Console.ReadKey();
    }

    private static Int32 Sum(Int32 n)
    {
      Int32 sum = 0;
      for (; n > 0; --n)
        checked{ sum += n;} //結(jié)果太大，拋出異常
      return sum;
    }
  }

class Program
  {
    static void Main(string[] args)
    {
      Task<Int32> t = new Task<Int32>(n => Sum((Int32)n), 1000);
      t.Start();
      //t.Wait();
      Task cwt = t.ContinueWith(task => Console.WriteLine("The result is {0}",t.Result));
      Console.ReadKey();
    }

    private static Int32 Sum(Int32 n)
    {
      Int32 sum = 0;
      for (; n > 0; --n)
        checked{ sum += n;} //結(jié)果溢出，拋出異常
      return sum;
    }
  }

public delegate string MyDelegate(object data);
  class Program
  {
    static void Main(string[] args)
    {
      MyDelegate mydelegate = new MyDelegate(TestMethod);
      IAsyncResult result = mydelegate.BeginInvoke("Thread Param", TestCallback, "Callback Param");

      //異步執(zhí)行完成
      string resultstr = mydelegate.EndInvoke(result);
    }

    //線程函數(shù)
    public static string TestMethod(object data)
    {
      string datastr = data as string;
      return datastr;
    }

    //異步回調(diào)函數(shù)
    public static void TestCallback(IAsyncResult data)
    {
      Console.WriteLine(data.AsyncState);
    }
  }

class Program
  {
    static int counter = 1;

    static void Main(string[] args)
    {
      Thread t1 = new Thread(new ThreadStart(F1));
      Thread t2 = new Thread(new ThreadStart(F2));

      t1.Start();
      t2.Start();

      t1.Join();
      t2.Join();

      System.Console.ReadKey();
    }

    static void F1()
    {
      for (int i = 0; i < 5; i++)
      {
        Interlocked.Increment(ref counter);
        System.Console.WriteLine("Counter++ {0}", counter);
        Thread.Sleep(10);
      }
    }

    static void F2()
    {
      for (int i = 0; i < 5; i++)
      {
        Interlocked.Decrement(ref counter);
        System.Console.WriteLine("Counter-- {0}", counter);
        Thread.Sleep(10);
      }
    }
  }

public void MonitorSomeThing()
    {
      try
      {
        Monitor.Enter(obj);
        dosomething();
      }
      catch(Exception ex)
      {
        
      }
      finally
      {
        Monitor.Exit(obj);
      }
    }

class SynchronizedCache 
  { 
    private ReaderWriterLockSlim cacheLock = new ReaderWriterLockSlim(); 
    private Dictionary<int, string> innerCache = new Dictionary<int, string>(); 
 
    public string Read(int key) 
    { 
      cacheLock.EnterReadLock(); 
      try 
      { 
        return innerCache[key]; 
      } 
      finally 
      { 
        cacheLock.ExitReaderLock(); 
      } 
    } 
 
    public void Add(int key, string value) 
    { 
      cacheLock.EnterWriteLock(); 
      try 
      { 
        innerCache.Add(key, value); 
      } 
      finally 
      { 
        cacheLock.ExitWriteLock(); 
      } 
    } 
 
    public bool AddWithTimeout(int key, string value, int timeout) 
    { 
      if (cacheLock.TryEnterWriteLock(timeout)) 
      { 
        try 
        { 
          innerCache.Add(key, value); 
        } 
        finally 
        { 
          cacheLock.ExitReaderLock(); 
        } 
        return true; 
      } 
      else 
      { 
        return false; 
      } 
    } 
 
    public AddOrUpdateStatus AddOrUpdate(int key, string value) 
    { 
      cacheLock.EnterUpgradeableReadLock(); 
      try 
      { 
        string result = null; 
        if (innerCache.TryGetValue(key, out result)) 
        { 
          if (result == value) 
          { 
            return AddOrUpdateStatus.Unchanged; 
          } 
          else 
          { 
            cacheLock.EnterWriteLock(); 
            try 
            { 
              innerCache[key] = value; 
            } 
            finally 
            { 
              cacheLock.ExitWriteLock(); 
            } 
            return AddOrUpdateStatus.Updated; 
          } 
        } 
        else 
        { 
          cacheLock.EnterWriteLock(); 
          try 
          { 
            innerCache.Add(key, value); 
          } 
          finally 
          { 
            cacheLock.ExitWriteLock(); 
          } 
          return AddOrUpdateStatus.Added; 
        } 
      } 
      finally 
      { 
        cacheLock.ExitUpgradeableReadLock(); 
      } 
    } 
 
    public void Delete(int key) 
    { 
      cacheLock.EnterWriteLock(); 
      try 
      { 
        innerCache.Remove(key); 
      } 
      finally 
      { 
        cacheLock.ExitWriteLock(); 
      } 
    } 
 
    public enum AddOrUpdateStatus 
    { 
      Added, 
      Updated, 
      Unchanged 
    }; 
  }

public Thread thrd;
    //創(chuàng)建一個(gè)可授權(quán)2個(gè)許可證的信號(hào)量，且初始值為2
    static Semaphore sem = new Semaphore(2, 2);
 
    public mythread(string name)
    {
      thrd = new Thread(this.run);
      thrd.Name = name;
      thrd.Start();
    }
    void run()
    {
      Console.WriteLine(thrd.Name + "正在等待一個(gè)許可證……");
      //申請(qǐng)一個(gè)許可證
      sem.WaitOne();
      Console.WriteLine(thrd.Name + "申請(qǐng)到許可證……");
      for (int i = 0; i < 4 ; i++)
      {
        Console.WriteLine(thrd.Name + "： " + i);
        Thread.Sleep(1000);
      }
      Console.WriteLine(thrd.Name + " 釋放許可證……");
      //釋放
      sem.Release();
    }
  }
 
  class mysemaphore
  {
    public static void Main()
    {
      mythread mythrd1 = new mythread("Thrd #1");
      mythread mythrd2 = new mythread("Thrd #2");
      mythread mythrd3 = new mythread("Thrd #3");
      mythread mythrd4 = new mythread("Thrd #4");
      mythrd1.thrd.Join();
      mythrd2.thrd.Join();
      mythrd3.thrd.Join();
      mythrd4.thrd.Join();
    }
  }

class Test
  {
    /// <summary>
    /// 應(yīng)用程序的主入口點(diǎn)。
    /// </summary>
    [STAThread]
    static void Main(string[] args)
    {
      bool flag = false;
      System.Threading.Mutex mutex = new System.Threading.Mutex(true, "Test", out flag);
      //第一個(gè)參數(shù):true--給調(diào)用線程賦予互斥體的初始所屬權(quán)
      //第一個(gè)參數(shù):互斥體的名稱
      //第三個(gè)參數(shù):返回值,如果調(diào)用線程已被授予互斥體的初始所屬權(quán),則返回true
      if (flag)
      {
        Console.Write("Running");
      }
      else
      {
        Console.Write("Another is Running");
        System.Threading.Thread.Sleep(5000);//線程掛起5秒鐘
        Environment.Exit(1);//退出程序
      }
      Console.ReadLine();
    }
  }

static void Main(string[] args)
    {
      string MutexName = "InterProcessSyncName";
      Mutex SyncNamed;   //聲明一個(gè)已命名的互斥對(duì)象
       try
      {
        SyncNamed = Mutex.OpenExisting(MutexName);    //如果此命名互斥對(duì)象已存在則請(qǐng)求打開
      }
      catch (WaitHandleCannotBeOpenedException)
      {
        SyncNamed = new Mutex(false, MutexName);     //如果初次運(yùn)行沒有已命名的互斥對(duì)象則創(chuàng)建一個(gè)
      }
      Task MulTesk = new Task
        (
          () =>         //多任務(wù)并行計(jì)算中的匿名方法，用委托也可以
          {
            for (; ; )     //為了效果明顯而設(shè)計(jì)
            {
              Console.WriteLine("當(dāng)前進(jìn)程等待獲取互斥訪問權(quán)......");
              SyncNamed.WaitOne();
              Console.WriteLine("獲取互斥訪問權(quán)，訪問資源完畢，按回車釋放互斥資料訪問權(quán).");
              Console.ReadLine();
              SyncNamed.ReleaseMutex();
              Console.WriteLine("已釋放互斥訪問權(quán)。");
            }
          }
        );
      MulTesk.Start();
      MulTesk.Wait();
    }

Parallel.For(0, 1000000, i =>
 {
  Stopwatch sw1 = new Stopwatch();
   sw1.Start();

    if (redisHelper.GetRedisOperation().Lock(key))
       {
     var tt = int.Parse(redisHelper.GetRedisOperation().StringGet("calc"));

     tt++;

     redisHelper.GetRedisOperation().StringSet("calc", tt.ToString());

     redisHelper.GetRedisOperation().UnLock(key);
            }
            var v = sw1.ElapsedMilliseconds;
            if (v >= 10 * 1000)
            {
              Console.Write("f");
        }
      sw1.Stop();
 });