/// <summary>
/// 多線程調(diào)用WCF
/// </summary>
/// <param name="select">調(diào)用WCF的方式，1=Restful，2=Tcp</param>
/// <param name="num"></param>
static void DoTest_MultiThread(string select, long num)
{
  int n_max_thread = 10; // 設(shè)置并行最大為10個(gè)線程
  int n_total_thread = 0; // 用來控制：主程序的結(jié)束執(zhí)行，當(dāng)所有任務(wù)線程執(zhí)行完畢
 
  ILog log_add = new LogHelper("Add_Thread");
  ILog log_del = new LogHelper("Del_Thread");
  ILog log_wait = new LogHelper("Wait_Thread");
  ILog log_set = new LogHelper("Set_Thread");
  ILog log_for = new LogHelper("For_Thread");
 
  Console.Title = string.Format("調(diào)用WCF的方式 => {0}, 調(diào)用次數(shù)=> {1}"
    , select == "1" ? "Restful" : "Socket"
    , num);
   
  List<int> list_Thread = new List<int>();
 
  System.Threading.AutoResetEvent wait_sync = new System.Threading.AutoResetEvent(false); // 用來控制：并發(fā)最大個(gè)數(shù)線程=n_max_thread
  System.Threading.AutoResetEvent wait_main = new System.Threading.AutoResetEvent(false); // 用來控制：主程序的結(jié)束執(zhí)行，當(dāng)所有任務(wù)線程執(zhí)行完畢
 
  DateTime date_step = DateTime.Now;
  for (long i = 0; i < num; i++)
  {
    Num_Query_Static++;
    if (i >0 && (i+1-1) % n_max_thread == 0) // -1 表示第max個(gè)線程尚未開始
    {
      //log_wait.Info(string.Format("thread n= {0},for i= {1}", dic_Thread.Count, i + 1));
      wait_sync.WaitOne(); // 每次并發(fā)10個(gè)線程，等待處理完畢后，在發(fā)送下一次并發(fā)線程
    }
    log_for.Info(string.Format("thread n= {0},for i= {1}", list_Thread.Count, i + 1));
 
    System.Threading.ThreadPool.QueueUserWorkItem
      ((data) =>
      {
        int id = System.Threading.Thread.CurrentThread.ManagedThreadId;
        System.Threading.Monitor.Enter(list_Thread);
        list_Thread.Add(id);
        System.Threading.Monitor.Exit(list_Thread);
 
        log_add.Info(string.Format("id={0}, count={1}", id, list_Thread.Count)); // 日志
 
        if (select == "1") // Restful方式調(diào)用
        {
          Query_Htty();
        }
        else
        {
          Query_Socket();
        }
 
        n_total_thread += 1;
        if (list_Thread.Count == (n_max_thread) || n_total_thread == num)
        {
          list_Thread.Clear();
          //log_set.Info(string.Format("thread n= {0},for i= {1}", dic_Thread.Count, i + 1));
          //wait_sync.Set(); 
          if (n_total_thread != num)
          {
            wait_sync.Set(); // 任務(wù)線程，繼續(xù)執(zhí)行
          }
          else
          {
            wait_main.Set(); // 主程序線程，繼續(xù)執(zhí)行
          }
        }
      }, list_Thread);
  }
 
  wait_main.WaitOne();
 
  Console.WriteLine(string.Format("總測(cè)試{0}次，總耗時(shí){1}, 平均耗時(shí){2}"
    , num
    , (DateTime.Now - date_step).ToString()
    , (DateTime.Now - date_step).TotalMilliseconds / num));
 
  Query_Thread();
}

private static ILog log = new LogHelper("SeqService"); // 日志
private static Dictionary<int, DateTime> dic_thread = new Dictionary<int, DateTime>(); // 線程列表
 
private static long Num = 0; // 線程個(gè)數(shù)
private static object lock_Num = 0; // 共享數(shù)據(jù)-鎖
 
/// <summary>
/// 在線申請(qǐng)流水號(hào)
/// </summary>
/// <returns></returns>
[WebGet(UriTemplate = "GetSeqNum/Json", ResponseFormat = WebMessageFormat.Json)]
public string GetSeqNumber()
{ 
  lock (lock_Num)
  {
    Num++;
    int id_thread = System.Threading.Thread.CurrentThread.ManagedThreadId;
    DateTime now = DateTime.Now;
    if (!dic_thread.TryGetValue(id_thread, out now))
    {
      dic_thread.Add(id_thread, DateTime.Now);
    }
 
  }
  string ret = DateTime.Now.ToString("yyyyMMdd") + Num.ToString(new string('0', 9)); 
 
  log.Info(string.Format("{0}, Thread={1}/{2}", ret, System.Threading.Thread.CurrentThread.ManagedThreadId, dic_thread.Count));
  return ret;
}