using System;
using System.Diagnostics;
using System.Runtime.InteropServices;
using System.Threading;
using System.Threading.Tasks; namespace TestProject
{
class Program
{
//异步：不阻塞主线程的一种编程方法
//多线程（new Thread）: 多个线程去做一个事情 (注意共享变量的问题)（无法监测是否完成）
//线程池（new ThreadPool）：省去线程重复创建回收的消耗。（无法检测执行任务是否完成）
//Task: Task在线程池的基础上进行了优化，并且可以检测到完成状态。
//Parallel：并行多个任务。（而且能监测完成状态）
//乐观锁悲观锁
static void Main(string[] args)
{
//int a = 0;
Stopwatch stopwatch = new Stopwatch(); #region 单线程
stopwatch.Start(); // 开始监视代码运行时间
for (int i = ; i < ; i++)
{
Console.WriteLine("thread:{0}", Thread.CurrentThread.ManagedThreadId);
Thread.Sleep();
}
// you code ....
stopwatch.Stop(); // 停止监视
ConsoleTime(stopwatch, "单线程");
#endregion #region ThreadPool（没办法检测是否完成哦！）这里监测到的时间是创建线程池所需要的时间
stopwatch.Start(); // 开始监视代码运行时间 ThreadPool.SetMaxThreads(, );
ThreadPool.SetMinThreads(, );
for (int i = ; i < ; i++)
{
ThreadPool.QueueUserWorkItem(new WaitCallback((obj) =>
{
Console.WriteLine("线程池输出： thread:{0}", Thread.CurrentThread.ManagedThreadId);
Thread.Sleep();
}), i.ToString());
}
// you code ....
stopwatch.Stop(); // 停止监视
ConsoleTime(stopwatch, "ThreadPool");
#endregion #region Thread（没办法检测完成！没有返回值没有办法检测状态。）这里监测到的时间仅仅只是创建这些线程所需要的时间。
stopwatch.Start(); // 开始监视代码运行时间
for (int i = ; i < ; i++)
{
Thread thread = new Thread(new ThreadStart(DoSomeThing));
thread.Start();
//Thread.Sleep(100);
}
// you code ....
stopwatch.Stop(); // 停止监视
ConsoleTime(stopwatch, "Thread");
#endregion #region Parallel
stopwatch.Start(); // 开始监视代码运行时间
var task = System.Threading.Tasks.Parallel.For(, , new ParallelOptions() { MaxDegreeOfParallelism = }, (i) =>
{
Console.WriteLine("{0},task:{1},thread:{2}", i, Task.CurrentId, Thread.CurrentThread.ManagedThreadId);
Task.Delay();
//提供的原子性操作，保证对a的值操作每一次都是原子性的
//System.Threading.Interlocked.Add(ref a, 1);
//a++;
});
stopwatch.Stop(); // 停止监视
ConsoleTime(stopwatch, "Parallel");
#endregion //Console.Write(a);
Console.ReadKey();
}
/// <summary>
/// 模拟做点什么同时输出当前线程id
/// </summary>
private static void DoSomeThing()
{
Console.WriteLine("DoSomeThing: thread:{0}", Thread.CurrentThread.ManagedThreadId);
Thread.Sleep();
}
/// <summary>
/// 模拟异步执行方法
/// </summary>
/// <returns></returns>
private static async Task DoSomeThing2()
{
await Task.Run(() =>
{
Console.WriteLine("DoSomeThing2: task:{0},thread:{1}", Task.CurrentId, Thread.CurrentThread.ManagedThreadId);
Thread.Sleep();
}
);
}
//输出当前代码段运行时间
private static void ConsoleTime(Stopwatch stopwatch, string BlockName)
{
TimeSpan timespan = stopwatch.Elapsed; //获取当前实例测量得出的总时间
Console.WriteLine("{0} ,代码执行时间：{1}(毫秒)", BlockName, timespan.TotalMilliseconds); //总毫秒数
stopwatch.Reset();
} }
}