上Parallel.Foreach迴路設置超時

Question

我要送我的自定義對象的List（「撥號」）從我的WCF服務。這目標客戶有5個屬性：ID，名稱，類型，Individual_avg，Dept_avg 。爲標識，名稱和類型的值從表中來，但Individual_avg和dept_avg是從第三方的服務。未來的要求是：

1. 負載靜態屬性 - 編號，名稱，類型從表
2. 在從第三方服務獲取其他2個屬性值的WCF服務中調用一個方法。

我必須在30秒後超時到第三方服務的調用。也就是說，如果服務需要超過30秒的響應時間，我必須發送的對象只有從表中獲取的3個屬性（ Id，Name，Type），並將其他2個屬性設置爲null。例如，在List中有5 Dials。產生5個線程來調用第三方服務來獲取2個屬性。如果在得到2 Dials的值後發生超時，則發送List，其中包含爲這2個Dials設置的所有屬性，並且僅爲其他3個設置Id，Name和Type撥號。我有以下代碼來實現它。

public DialResponse GetDials(DialRequest req) 
{ 
    DialResponse response = new DialResponse(); 
    var indiDials = new List<DialDetails>(); 
    foreach (var c in indiDialIdToShow) 
    { 
     var indiObj = _repository.FindQueryable<DashboardDial_Tbl>().Where(p => p.DialId == c.DialIdToShow && p.IsActive == true).Select(p => new DialDetails() 
      { 
       Id = p.DialId, 
       Name = p.DialName, 
       Type = p.DialType, 
      }).SingleOrDefault(); 
     indiDials.Add(indiObj); 
    } 
var timeout = 30000; // 30 seconds 
var cts = new CancellationTokenSource(); 
var token = new CancellationToken(); 
token = cts.Token; 
var myOptions = new ParallelOptions { CancellationToken = cts.Token }; 
using (var t = new Timer(_ => cts.Cancel(), null, timeout, -1)) 
{ 
    Parallel.ForEach(indiDials, myOptions, c => 
    { 
     DialDetails newDial = c; 
     ReadConfig(c.Id, userName, ref newDial); 
     //send a reference to the "dial" object and set the 2 properties on the object 

    }); 
} 
response.DialsList = indiDials; 
} 

private void ReadConfig(string userName,ref DialDetails dialObj) 
{ 
    //call the 3rd party service 
    dialObj.Individual_avg = serviceResponse.someValue; 
    dialObj.dept_avg = serviceResponse.anotherValue; 
} 

要測試「超時」的功能，我把在"ReadConfig"Thread.Sleep(40000) method.This返回「撥號」，而不是發送「撥號」的只有3個屬性（ID，名稱，類型）的空單組。我應該做些什麼改變才能使這段代碼按預期工作？

Answer 1

ReadConfig正在本地執行修改，因此indiDials未更新。您可以將其轉換爲函數以返回修改的項目。示例代碼：

private DialDetails ReadConfig(string userName,ref DialDetails dialObj) 
{ 
    //call the 3rd party service 
    dialObj.Individual_avg = serviceResponse.someValue; 
    dialObj.dept_avg = serviceResponse.anotherValue; 

    retun dialObj; 
} 

而且從環這樣稱呼它的List修改：

indiDials[indiDials.IndexOf(newDial)] = ReadConfig(userName, ref newDial);