請教一下，同事把WCF服務端所有服務方法都用Task.Factory.StartNew包了一下，我覺得是錯誤的做法，如何說服他改正？
WCF服務端代碼：
public List<TpDevice> GetCameraListAll()
{
if (HI.Get<ISecurityImp>().CheckTicket())
{
var result = FuncUtil.TryDoFunc<List<TpDevice>>(() => { return HI.Get<IBaseDataImp>().GetCameraListAll(); });
return result;
}
return new List<TpDevice>();
}
說明：HI.Get<ISecurityImp>().CheckTicket()是校驗ticket票據
FactoryStartNew.StartNewThread方法：
/// <summary>
/// 通過執行緒運行函式
/// </summary>
/// <typeparam name="TResult">回傳值型別</typeparam>
/// <param name="action">運行函式</param>
/// <returns>回傳值</returns>
public static TResult StartNewThread<TResult>(Func<TResult> action)
{
try
{
TResult bRst;
System.Threading.Tasks.Task<TResult> va = System.Threading.Tasks.Task.Factory.StartNew<TResult>(() =>
{
return action();
})
.ContinueWith<TResult>(o => { return o.Result; });
bRst = va.Result;
return bRst;
}
catch (System.Exception ex)
{
m_Log.Error(ex);
return default(TResult);
}
}
uj5u.com熱心網友回復：
上貼已經說了，不是錯誤不錯誤的問題。是系統需要，以及這寫法多余try
{
TResult bRst;
System.Threading.Tasks.Task<TResult> va = System.Threading.Tasks.Task.Factory.StartNew<TResult>(() =>
{
return action();
})
.ContinueWith<TResult>(o => { return o.Result; });
bRst = va.Result;
return bRst;
}
catch (System.Exception ex)
{
m_Log.Error(ex);
return default(TResult);
}
紅色兩句多余，自己品
1.你為啥要第一句？？？？
2.第2句，你說你異步？你那里異步了，這里寫的明明就是同步
就像前面說的例子，煮飯的時候同時炒菜，才是并行。飯好了電飯煲滴一聲通知你才是異步。
現在是什么？現在是你倒是自己不煮飯，讓另外的人給你煮飯，只是你不是讓電飯煲滴一聲通知你，你就站在電飯煲面前盯著那個燈
比較一下下面的代碼
執行緒1 xx=執行緒任務1+2+3+------10000000
where(xx完成沒有)
{
}
so，這個where干啥呢？當然是同步呆在那里發呆，等著xx完成
所以上貼一致說的是，“多余”請正常的寫 async/await，而不是假裝搞個“高大上的假異步”
uj5u.com熱心網友回復：
該說的上貼已經說過了。uj5u.com熱心網友回復：
一個靠譜的回答uj5u.com熱心網友回復：
其實微軟也給了一套標準的同步變異步的代碼這是用來兼容早期的實作的庫大多是同步的，當然也可以看成那些基于訊息，基于事件的庫異步封裝收到
比如這里經常問的問題，給串口發一個指令，串口回傳一個訊息，這程序是異步的。或者你傳統的dll代碼，他通過事件或者回呼函式異步通知。我們想把收發異步等待統一操作的時候，就有統一的手段
偽代碼
Task<result> waitmsg()
{
TaskCompletionSource<result> tcs=new TaskCompletionSource<result>();
//比如pinvoke呼叫dll，他異步回呼給我
callback委托 callback = p => { tcs.TrySetResult(p); }
xxxx.callmethod(callback);
return tcs.Task
}
通過這樣的手段，我們可以把任何需要等待執行拿結果的東西，都變成我們我的標準異步方法
uj5u.com熱心網友回復：
這種寫法，大概可以提高多處理器系統的CPU利用率。當然，這對客戶端來講是沒啥區別的，如果客戶端體現出異步，那要建立基于net.tcp的雙工通訊，客戶端發起訂閱，服務端處理，處理完了將結果發送給客戶端，期間客戶端可以干別的事情。
uj5u.com熱心網友回復：
修正一下，WCF本身就是多執行緒執行的，應該考慮到了CPU使用率的問題，所以這種寫法確實是多此一舉。
uj5u.com熱心網友回復：
糾結了一天，這個帖子他也看了，也沒有說服同事，我都快忘了問題的初衷了。
我學java的代碼，攔截器統一處理例外，寫錯誤日志，方法里沒有try catch，也不用每個方法都校驗證一下ticket，在攔截器里統一處理，一個方法少寫一行代碼，幾百個方法就少寫幾百行代碼，能省很多事。這些都需要論證。
public List<TpDevice> GetCameraListAll()
{
return HI.Get<IBaseDataImp>().GetCameraListAll();
}
這樣簡捷的代碼它不香嗎？你加個try catch，加個checkTicket，out引數還要額外處理，專案中有幾百個服務方法。
你加個try catch當然沒有問題，加個checkTicket，也就多寫一行代碼，再用task包一下，也沒有問題，系統也不崩潰了。但也失去了論證更好方法的機會。以后，至少在這個公司中，所有的專案都這樣干，因為上一個專案就這樣干，它沒有問題。
uj5u.com熱心網友回復：
我已經不在那個專案中，只能寫demo驗證，如此執著的意義是什么呢using SunCreate.Common.ComLib;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
namespace FactoryStartNewDemo
{
public partial class Form1 : Form
{
private System.Windows.Forms.Timer _timer = new System.Windows.Forms.Timer();
public Form1()
{
InitializeComponent();
}
private void Form1_Load(object sender, EventArgs e)
{
ThreadPool.SetMinThreads(100, 100);
_timer.Tick += _timer_Tick;
_timer.Interval = 500;
_timer.Start();
}
private void button1_Click(object sender, EventArgs e)
{
for (int i = 0; i < 10; i++) //模擬10個服務執行緒
{
Task.Run(() => //模擬服務執行緒
{
string result = FactoryStartNew.StartNewThread<string>(() =>
{
Thread.Sleep(5000); //模擬服務耗時
return "測驗567";
});
});
}
}
private void button2_Click(object sender, EventArgs e)
{
for (int i = 0; i < 10; i++) //模擬10個服務執行緒
{
Task.Run(() => //模擬服務執行緒
{
string result = Utils.ActionUtil.TryDoFunc<string>(() =>
{
Thread.Sleep(5000); //模擬服務耗時
return "測驗567";
});
});
}
}
private void _timer_Tick(object sender, EventArgs e)
{
int a1, b1, a2, b2;
ThreadPool.GetMaxThreads(out a1, out b1);
ThreadPool.GetAvailableThreads(out a2, out b2);
int a3 = a1 - a2;
int b3 = b1 - b2;
textBox1.Text = a3.ToString();
}
}
}
using SunCreate.Common.ComLib;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
using Utils;
namespace FactoryStartNewDemo
{
public partial class Form1 : Form
{
private int _n = 100000;
private int _sleepTime = 500;
public Form1()
{
InitializeComponent();
}
private void Form1_Load(object sender, EventArgs e)
{
}
/// <summary>
/// 現象：記憶體不會爆，但處理速度慢，因為FactoryStartNew.StartNewThread是同步代碼
/// </summary>
private void button1_Click(object sender, EventArgs e)
{
Task.Run(() =>
{
for (int i = 1; i <= _n; i++)
{
string data = CreateTestData();
FactoryStartNew.StartNewThread<string>(() =>
{
string str = data;
Thread.Sleep(_sleepTime); //模擬耗時
return str;
});
Log("已處理數：" + i);
}
});
}
/// <summary>
/// 現象：記憶體會爆，
/// </summary>
private void button2_Click(object sender, EventArgs e)
{
Task.Run(() =>
{
for (int i = 1; i <= _n; i++)
{
string data = CreateTestData();
MyThreadPool.Start((obj) =>
{
string str = obj.ToString();
Thread.Sleep(_sleepTime); //模擬耗時
}, data);
Log("已處理數：" + i);
}
});
}
/// <summary>
/// 現象：記憶體會爆，
/// </summary>
private void button3_Click(object sender, EventArgs e)
{
Task.Run(() =>
{
for (int i = 1; i <= _n; i++)
{
string data = CreateTestData();
TaskHelper.CalcTask.Run((obj) =>
{
string str = obj.ToString();
Thread.Sleep(_sleepTime); //模擬耗時
}, data);
Log("已處理數：" + i);
}
});
}
/// <summary>
/// 現象：記憶體不會爆，處理速度也慢，ActionUtil.TryDoFunc也是同步代碼，但沒有包Task.Factory.StartNew
/// </summary>
private void button4_Click(object sender, EventArgs e)
{
Task.Run(() =>
{
for (int i = 1; i <= _n; i++)
{
string data = CreateTestData();
ActionUtil.TryDoFunc(() =>
{
string str = data;
Thread.Sleep(_sleepTime); //模擬耗時
return str;
});
Log("已處理數：" + i);
}
});
}
/// <summary>
/// 改造：只要處理速度比資料產生的速度快(記憶體來得及釋放)，記憶體就不會爆，但實際專案我不知道資料生產速度有多快，引數沒法設定
/// </summary>
private void button5_Click(object sender, EventArgs e)
{
Task.Run(() =>
{
for (int i = 1; i <= _n; i++)
{
if (i % 50 == 0) Thread.Sleep(500);
string data = CreateTestData();
TaskHelper.RequestTask.Run((obj) =>
{
string str = obj.ToString();
Thread.Sleep(_sleepTime); //模擬耗時
}, data);
Log("已處理數：" + i);
}
});
}
/// <summary>
/// 現象：記憶體會爆，微軟的Task.Factory.StartNew也不好使
/// </summary>
private void button6_Click(object sender, EventArgs e)
{
Task.Run(() =>
{
for (int i = 1; i <= _n; i++)
{
string data = CreateTestData();
Task.Factory.StartNew(() =>
{
string str = data;
Thread.Sleep(_sleepTime); //模擬耗時
return str;
});
Log("已處理數：" + i);
}
});
}
/// <summary>
/// 改造：記憶體不會爆，還要兼顧處理速度
/// </summary>
private void button7_Click(object sender, EventArgs e)
{
//todo：???????????
}
#region 生成測驗資料
/// <summary>
/// 生成測驗資料
/// </summary>
private string CreateTestData()
{
try
{
StringBuilder sb = new StringBuilder();
for (int j = 0; j < 100000; j++)
{
sb.Append("sadfsadf;asdjga;dsgkja;fdsk");
}
string result = sb.ToString();
return result;
}
catch (Exception ex)
{
MessageBox.Show("記憶體爆了：" + ex.Message);
return string.Empty;
}
}
#endregion
#region Log
private void Log(string msg)
{
if (this.InvokeRequired)
{
this.BeginInvoke(new Action(() =>
{
textBox1.AppendText(msg + "\r\n");
}));
}
else
{
textBox1.AppendText(msg + "\r\n");
}
}
#endregion
}
}
uj5u.com熱心網友回復：
不必糾結，專案代碼不出錯，能正常運行就行了。畢竟不是通用組件，需要做到很精致。Task提供是并行計算的方案，能不能提高性能還要看有沒有并行計算的硬體條件。系統的性能優化主要還是在演算法上，比如通過減少IO的次數，降低程式運行的時間復雜度等。
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/188492.html
標籤：C#