設計了一個資料采集系統，通過執行緒阻塞的方式，保證四個采集執行緒每次采集回來的資料都是同時的，在回圈采集程序100次后，停止采集。但是在應用時候發現了一個問題，第一次點擊button1，資料可以很好的采集并保存，第二次、第三次也都沒有問題，但是，每次除錯中，第四次采集資料時總會出現資料丟失的問題，就是正常情況下每個采集執行緒完成后應當保存有100個資料，但從第四次開始，資料一般只有80多個。之后，隨著采集次數增多，資料缺失會越來越嚴重。（資料丟失的現象很穩定的出現在第四次）
我的代碼貼在下面，求大佬們幫我看一眼，該怎么解決這個問題。
[DllImport("winmm")]
public static extern uint timeGetTime();
public static ManualResetEvent _mre = new ManualResetEvent(false);
private static Object thisLock = new object();
Thread th1;
Thread th2;
Thread th3;
Thread th4;
Thread th;
private void button1_Click(object sender, EventArgs e)//button1是開始按鈕，單機開始采集資料
{
th1 = new Thread(getdata);
th1.Start();
th2 = new Thread(getdata);
th2.Start();
th3 = new Thread(getdata);
th3.Start();
th4 = new Thread(getdata);
th4.Start();
th = new Thread(timer);
th.Start();
}
void timer()
{
int t = 0;
int Millisecond = 100; //時鐘觸發間隔為100ms
while (t < 100) //定時器觸發100次后自動結束
{
_mre.Reset();
uint timerstart = timeGetTime();
uint i = 0;
while (i < Millisecond)
{
i = timeGetTime() - timerstart;
}
timerstart = timeGetTime();
_mre.Set();
t = t + 1;
}
th1.Abort(); //銷毀執行緒
th2.Abort(); //銷毀執行緒
th3.Abort(); //銷毀執行緒
th4.Abort(); //銷毀執行緒
th.Abort(); //銷毀執行緒
}
void getdata()
{
int nowtimes = 0;
while (nowtimes < 100)
{
Form1._mre.WaitOne();
lock (thisLock)
{
GetValue(); //從傳感器獲取資料
SaveValue(); //資料保存，將采集的資料保存到csv文本中
nowtimes = nowtimes + 1;
}
}
}
uj5u.com熱心網友回復：
執行緒阻塞，那就等于單執行緒GetValue(); //從傳感器獲取資料
SaveValue();
這些都在鎖里面呢
uj5u.com熱心網友回復：
看不出你這個代碼，從哪里能得出，每次必定為100個任何保證。就是你說的前3次，其實依舊是“巧合”，碰巧cpu在100*100ms左右把100個任務完成了
貌似好像你這個描述，你這個處理要求，我好像有些印象。嗯，看了一下你以前的帖子，果然還是那個問題。
那個帖子已經提醒你了，執行緒會堆疊。如果前面的不走，后面繼續加，最終是肯定是這結果。
按照你目前的描述，偽代碼
slim=slim(3) //下異步鎖，并限制最大次數
采集調度()
{
CancelToken //這個我們不清楚你環境，需不要需要設定超時，強制退出，就自己看著辦了
await slim.asynwait(); //異步鎖，保證你前面有3個在運行，后面一個先等著
for(i t0 100)
{
結果[] temp= await Task.WhenAll(采集資料1,采集資料2) //他們可以異步并行
}
//這里100次并行采集結束。至于保存其實可以延后。所以這里另外啟動一個save task。或者干脆直接用TaskCompletionSource丟給外面，讓外面自己決定怎么處理他
slim.釋放();
}
task<結果> 采集資料1()
{
}
task<結果> 采集資料2()
{
}
uj5u.com熱心網友回復：
task<結果> 采集資料1(){
task.yield()
}
task<結果> 采集資料2()
{task.yield()
}
結合你上一個帖子，這里可以放上task.yield,告訴cpu我先掠過，下一輪在說。這樣可以保證你多task能盡量快速進入準備狀態。那么就可能被同時被系統快速分配。同時task調度器可以使用讓他盡可能被公平調度
uj5u.com熱心網友回復：
Form1._mre.WaitOne(); 這行代碼是什么邏輯uj5u.com熱心網友回復：
GetValue();SaveValue();
這兩行代碼里是不是報例外了
uj5u.com熱心網友回復：
異步獲取，同步存盤嗎？傳感器沒有資料緩沖區吧，接收執行緒卡住了，資料不就白扔了，可以把采集到的資料先放一個同步佇列里，再開一個執行緒一個取出來慢慢保存，這樣就不會資料丟失了，除非程式中途例外退出。uj5u.com熱心網友回復：
你這個設計有問題，采集的資料是怎么來的？是不是發送方提供的？如果發送方提供的資料不是準時的，你怎么保證你采集的資料是準確的？所以你這個設計就有問題，你要求：1）發送方沒問題，2）采集方沒問題。這是一種強耦合。
你從設計上，應該解耦。
首先準不準時發，那是發送方的問題。其次，你只要保證每一個采集點，都能采集到資料。然后，時間是不是一致，你記錄下采集時間，也可以作為后驗證。
在這種設計下，發送=》采集，可以處理為一個事件機制。
uj5u.com熱心網友回復：
你同時并發 500個執行緒分別執行GetValue(); //從傳感器獲取資料連續測驗10次，你能每一次都準確的到500個結果嗎？
SaveValue();
實際上在粗糙的 GetValue 或者 SaveValue 內部就有沖突，結果是很混亂的。之所你問題好像還沒有嚴重到完全不能用的地步，是因為你寫的這個只有“4執行緒”的方法太簡單了，有一點兒亂。大亂大治，小亂則是耗費時間。所以你認真地并發幾十個、上百個執行緒去測驗，以測驗為準。不要只弄一個很簡單的程式，然后解決不了技術設計問題。
uj5u.com熱心網友回復：
小程式，小功能，反而很繁瑣很亂，堆砌了技術，這樣就產生了因小失大的毛病。任何一個貌似用于并發處理的程序，我們都應該拿幾十個、上百個執行緒（或者Task）異步并發測驗。注意是真正的異步并發，而不是用信號量、用異步的語法來做同步順序阻塞的事情。這樣就好像把一步步功能測穩定了，再來組合在一起。而組合的是時候就使用盡量簡明清晰的思路，例如 #2 樓所寫的
List<Task> tasks;這樣的比較現代的更結構化的代碼。當有編程設計效率高10倍的異步并發代碼時，沒有人喜歡研究詭異的信號量同步。
....
tasks.Add(Task.Run(()=>{
do1();
do2();
}));
結果[] temp= await Task.WhenAll(tasks);
uj5u.com熱心網友回復：
新的異步編程開發的結構化語法，這是從“現代”的角度說的。回到了并發測驗 GateValue 和 SaveValue 有沒有在多執行緒運行時內部存盤狀態混亂沖突的問題，這是從測驗來說的。如果先用幾十個執行緒把核心程序測驗過去了，然后再討論主程式有沒有混亂問題，這就好像是步子邁穩健了再跨樓梯。新語法是“術”，并發測驗是“道”，二者相輔相成。你不習慣于道，各種識訓亂使用，那么也可以通過學習現代的術來重新修道。uj5u.com熱心網友回復：
讓我們來先捋一捋你的需求吧。1. 你應該是外接了4臺設備
2. 設備不能主動向服務器發起資料（推資料），只能服務器電腦去訪問設備（拉資料）
3. 你打算間隔100ms，從這4臺設備里分別讀取他們的資料，并將這4個資料保存到一個獨立的檔案下。
限定條件有：
1. 4個設備需要獲取同一時刻的資料，也就是說必須要保證在同一個時刻下同時獲取資料
如果還有限定條件請補充，只有補充后，才好幫你重新設計代碼結構。
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/26278.html
標籤：C#
上一篇：找大牛幫忙搭建下
下一篇：C#呼叫攝像頭，界面顯示黑屏