异步和多线程Thread

////2 通过IsComplate等待，卡界面--主线程在等待，边等待边提示
////（ Thread.Sleep(200);位置变了，少了一句99.9999）
int i = 0;
while (!asyncResult.IsCompleted)
{
    if (i < 9)
    {
        Console.WriteLine($"bingle{++i * 10}%....");
    }
    else
    {
        Console.WriteLine($"bingle99.999999%....");
    }
    Thread.Sleep(200);
}
Console.WriteLine("已经完成！");

asyncResult.AsyncWaitHandle.WaitOne();//直接等待任务完成
asyncResult.AsyncWaitHandle.WaitOne(-1);//一直等待任务完成
asyncResult.AsyncWaitHandle.WaitOne(1000);//最多等待1000ms，超时就不等了

//4 EndInvoke 即时等待, 而且可以获取委托的返回值 一个异步操作只能End一次
action.EndInvoke(asyncResult);//等待某次异步调用操作结束

ParameterizedThreadStart method = o => this.DoSomethingLong("btnThread_Click");
Thread thread = new Thread(method);
thread.Start("123");//开启线程，执行委托的内容

下面这些，是Obselte的api
 //thread.Suspend();//暂停
 //thread.Resume();//恢复    真的不该要的，暂停不一定马上暂停；让线程操作太复杂了
 //thread.Abort();
 ////线程是计算机资源，程序想停下线程，只能向操作系统通知(线程抛异常)，
 ////会有延时/不一定能真的停下来

while (thread.ThreadState != ThreadState.Stopped)
{
    Thread.Sleep(200);//当前线程休息200ms
}

//2 Join等待
thread.Join();//运行这句代码的线程，等待thread的完成
thread.Join(1000);//最多等待1000ms

thread.IsBackground = false;//默认是false 前台线程，进程关闭，线程需要计算完后才退出
//thread.IsBackground = true;//关闭进程，线程退出

private void ThreadWithCallBack(ThreadStart threadStart, Action actionCallback)
{
    //Thread thread = new Thread(threadStart);
    //thread.Start();
    //thread.Join();//错了，因为方法被阻塞了
    //actionCallback.Invoke();

    //上面那种方式错了， 应该先用threadStart，再调用callback

    ThreadStart method = new ThreadStart(() =>
    {
        threadStart.Invoke();
        actionCallback.Invoke();
    });
    new Thread(method).Start();
}

 ThreadStart threadStart = () => this.DoSomethingLong("btnThread_Click");
 Action actionCallBack = () =>
   {
       Thread.Sleep(2000);
       Console.WriteLine($"This is Calllback {Thread.CurrentThread.ManagedThreadId.ToString("00")}");
   };
 this.ThreadWithCallBack(threadStart, actionCallBack);

private Func<T> ThreadWithReturn<T>(Func<T> func)
{
    T t = default(T);
    ThreadStart threadStart = new ThreadStart(() =>
    {
        t = func.Invoke();
    });
    Thread thread = new Thread(threadStart);
    thread.Start();

    return new Func<T>(() =>
    {
        thread.Join();
        //thread.ThreadState
        return t;
    });
}

 Func<int> func = () =>
     {
         Thread.Sleep(5000);
         return DateTime.Now.Year;
     };
 Func<int> funcThread = this.ThreadWithReturn(func);//非阻塞
 Console.WriteLine("do something else/////");
 Console.WriteLine("do something else/////");
 Console.WriteLine("do something else/////");
 Console.WriteLine("do something else/////");
 Console.WriteLine("do something else/////");

 int iResult = funcThread.Invoke();//阻塞
 Console.WriteLine(iResult);

ThreadPool.QueueUserWorkItem(o => this.DoSomethingLong("btnThreadPool_Click1"));
ThreadPool.QueueUserWorkItem(o => this.DoSomethingLong("btnThreadPool_Click2"), "bingle");

 //等待
 ManualResetEvent mre = new ManualResetEvent(false);
 //false---关闭---Set打开---true---WaitOne就能通过
 //true---打开--ReSet关闭---false--WaitOne就只能等待
 ThreadPool.QueueUserWorkItem(o =>
 {
     this.DoSomethingLong("btnThreadPool_Click1");
     mre.Set();
 });
 Console.WriteLine("Do Something else...");
 Console.WriteLine("Do Something else...");
 Console.WriteLine("Do Something else...");

 mre.WaitOne();
 Console.WriteLine("任务已经完成了。。。");

ThreadPool.SetMaxThreads(8, 8);
ManualResetEvent mre = new ManualResetEvent(false);
for (int i = 0; i < 10; i++)
{
    int k = i;
    ThreadPool.QueueUserWorkItem(t =>
    {
        Console.WriteLine($"{Thread.CurrentThread.ManagedThreadId.ToString("00")} show {k}");
        if (k == 9)
        {
            mre.Set();
        }
        else
        {
            mre.WaitOne();
        }
    });
}
if (mre.WaitOne())
{
    Console.WriteLine("任务全部执行成功！");
}