using System;
using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading;using System.Threading.Tasks;namespace TaskConsole
{  class Program
  {    static void Main(string[] args)
    {      //當(dāng)前線程標(biāo)識      Console.WriteLine(Thread.CurrentThread.GetHashCode());
      Task task = new Task(run);
      Console.WriteLine("任務(wù)標(biāo)識：" + task.GetHashCode() + "，狀態(tài)：" + task.Status);//狀態(tài)       task.Start();
      Console.WriteLine("任務(wù)標(biāo)識：" + task.GetHashCode() + "，狀態(tài)：" + task.Status);//狀態(tài)      //任務(wù)完成后執(zhí)行新任務(wù)
      Action ation = new Action(taskStart);
      task.ContinueWith(ation);

      Console.Read();
    }    public static void taskStart(Task task)
    {
      task = new Task(run);
      task.Start();      //如果注釋上面兩句話，則任務(wù)標(biāo)識為 task.ContinueWith(ation)中task的任務(wù)
      Console.WriteLine("任務(wù)標(biāo)識：" + task.GetHashCode() + "，狀態(tài)：" + task.Status + ",當(dāng)前線程：" + Thread.CurrentThread.GetHashCode());//狀態(tài)       
    }    public static void run()
    { 
      Console.WriteLine("this is run");
    }
  }
}

public class Program
 {
 static void Main(string[] args)
 { 
 WaitForSimpleNestedTask();
 Console.WriteLine("=====================================================");
 SimpleNestedTask();
 Thread.SpinWait(600000);//等待SimpleNestedTask結(jié)束 再運(yùn)行
 Console.WriteLine("=====================================================");
 //SimpleNestedTaskAttachedToParent();
 Console.Read();
 }
 static void WaitForSimpleNestedTask()
 {
 var outer = Task.Factory.StartNew(() =>
 {
 Console.WriteLine("Outer1 task executing.");

 var nested = Task.Factory.StartNew(() =>
 {
 Console.WriteLine("Nested1 task starting.");
 Thread.SpinWait(5000000);
 Console.WriteLine("Nested1 task completing.");
 return 42;
 });
 return nested.Result;
 return 1;
 });
 Console.WriteLine("Outer1 has returned {0}.", outer.Result);
 }
 static void SimpleNestedTask()
 {
 var parent = Task.Factory.StartNew(() =>
 {
 Console.WriteLine("Outer2 task executing.");

 var child = Task.Factory.StartNew(() =>
 {
 Console.WriteLine("Nested2 task starting.");
 Thread.SpinWait(500000);
 Console.WriteLine("Nested2 task completing.");
 });
 });
 parent.Wait();
 Console.WriteLine("Outer2 has completed."); 
 }

 static void SimpleNestedTaskAttachedToParent()
 {
 var parent = Task.Factory.StartNew(() =>
 {
 Console.WriteLine("Outer3 task executing.");

 var child = Task.Factory.StartNew(() =>
 {
 Console.WriteLine("Nested3 task starting.");
 Thread.SpinWait(500000);
 Console.WriteLine("Nested3 task completing.");
 }, TaskCreationOptions.AttachedToParent);
 });
 parent.Wait();
 Console.WriteLine("Outer has completed.");
 }

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace ParallelConsole
{
 class Program
 {
 
 //定義集合大小為51個，也可以不定義大小
 static BlockingCollection blocking = new BlockingCollection(51);
 
 static void Main(string[] args)
 {
  

  blocking = new BlockingCollection();
  Console.WriteLine("當(dāng)前blocking為：" + blocking.IsCompleted + "設(shè)置了集合大小count一樣是0，blocking.Count:" + blocking.Count());
  //當(dāng)前線程標(biāo)識
  Console.WriteLine(Thread.CurrentThread.GetHashCode());

  for (int i = 0; i < 3; i++)
  {
  ////如果添加到第3個，就設(shè)置添加完成，這時在添加就會拋異常
  //if (i == 3)
  //{
  // blocking.CompleteAdding();
  //}
  
  Action action = new Action(run);
  Task task = new Task(action,i); 
  task.RunSynchronously(); 
  }
  Console.WriteLine("設(shè)置添加完成前：" + blocking.IsAddingCompleted);
  //設(shè)置添加完成后
  blocking.CompleteAdding();
  Console.WriteLine("設(shè)置添加完成后：" + blocking.IsAddingCompleted);
  #region 同步取 取3個
  //for (int i = 0; i < 3; i++)
  //{
  // Action actionTake = new Action(take);
  // actionTake();
  //}
  #endregion
  //并發(fā)讀取
  
  #region 并發(fā)步取 取3個
  //blocking.IsCompleted 只有當(dāng)集合被添加進(jìn)內(nèi)容，然后又都被取光了以后，他才會等于ture，否則都是false
  //當(dāng)IsCompleted為ture時，就不能再取了否則會拋異常
  
  //同時取，結(jié)果是 
  //blocking:0
  //blocking:2
  //blocking:1
  if (!blocking.IsCompleted)//如果集合沒取光
  {
  Action actionTake2 = new Action(take);
  Parallel.Invoke(actionTake2, actionTake2, actionTake2);
  }
  #endregion

  Console.WriteLine("當(dāng)前blocking為：" + blocking.IsCompleted + ",blocking數(shù)量為：" + blocking.Count());
  //數(shù)據(jù)被取光了以后， blocking.Count()為0
  Console.Read();
 }

 public static void take()
 {
  //同步取，blocking.Count()會真實(shí)的表現(xiàn)，而異步取，Count是不準(zhǔn)確的，因?yàn)槲胰ount的時候，可能集合已經(jīng)又被取出數(shù)據(jù)了，測試10次肯定會出現(xiàn)不真實(shí)的情況
  Console.WriteLine("blocking:" + blocking.Take() + ",blocking數(shù)量為：" + blocking.Count());
 }
 public static void run(object i)
 {
  int currentI = int.Parse(i.ToString());
  blocking.TryAdd(currentI); 
 }
 }
}