2

私は使用Silverlight 5してWCF data serviceおり、Silverlight WCF データ サービス クライアント ライブラリをインストールしました。

理想的には、 を実行するDataServiceQuery<T>.BeginExecuteと、ワーカー スレッドでコールバックが返されるはずですが、私の場合は UI スレッドで返されます。

懸念される理由は、ペイロードが非常に大きく、オブジェクトへの応答を具体化するのに約 6 ～ 7 秒かかるためです ( DataServiceQuery<T>.EndExecute method)。したがって、UI スレッドで実行されている場合、UI が 6 ～ 7 秒間ブロックされます。

ワーカー スレッドで応答を取得し、ワーカー スレッドで応答を具体化してから、UI スレッドに切り替えて UI を更新するにはどうすればよいですか。

誰かが同様の問題に直面していますか？

これは私のコードです。

private void getRealTimeAssetProfileQuery(Guid assetProfileID, DateTime fromDate, DateTime toDate)
{
    dateRanges[assetProfileID].Add(new Range<DateTime>(fromDate, toDate));

    context = ServiceAgent.Context;
    var qry = (from o in context.RealTimeProfilePoint
               where o.ProfileID == assetProfileID && o.PointTime >= fromDate && o.PointTime <= toDate
               orderby o.PointTime descending
               select o) as DataServiceQuery<RealTimeProfilePoint>;

    qry = qry.AddQueryOption("$expand", "Profile");
    qry = qry.AddQueryOption("$expand", "Profile/ProfileType");


    dynamic asyncState = new
    {
        assetProfileID = assetProfileID,
        fromDate = fromDate,
        toDate = toDate
    };


    Uri qryUri = new Uri(qry.ToString());

    context.BeginExecute<RealTimeProfilePoint>(qryUri, new AsyncCallback(realTimeCallBack), asyncState);
}

void realTimeCallBack(IAsyncResult asyncResult)
{
    if (Deployment.Current.Dispatcher.CheckAccess())
        raiseTrace("Data Service Response On UI Thread \n");
    else
        raiseTrace("Data Service Response On worker Thread \n");


    dynamic asyncState = asyncResult.AsyncState as dynamic;

    Guid assetProfileID = asyncState.assetProfileID;
    DateTime fromDate = asyncState.fromDate;
    DateTime toDate = asyncState.toDate;

    IEnumerable<RealTimeProfilePoint> profilePoints = context.EndExecute<RealTimeProfilePoint>(asyncResult);

    List<RealTimeProfilePoint> lstProfilePoint = profilePoints.ToList();

    if (((QueryOperationResponse)profilePoints).GetContinuation() != null)
    {
        Uri qryUri = ((QueryOperationResponse)profilePoints).GetContinuation().NextLinkUri;

        context.BeginExecute<RealTimeProfilePoint>(qryUri, new AsyncCallback(realTimeCallBack), asyncState);
    }

    if (lstProfilePoint.Count > 0)
    {
        var assetProfile = lstProfilePoint[0].Profile;

        Instance.addRealTimePoints(assetProfile, lstProfilePoint);

        raiseTrace(
               "Fetching Real Time Profile Points from Server for AssetProfileID " +
               assetProfileID.ToString() + " : " +
               lstProfilePoint.Count.ToString() + " record(s) found for" +
               fromDate.ToUtcTime().ToString() + " - " + toDate.ToUtcTime().ToString() +
               " peiod.");
    }
}
4

1 に答える 1

0

(バックグラウンド) スレッドからリクエストを開始します。

 dynamic asyncState = new
 {
     assetProfileID = assetProfileID,
     fromDate = fromDate,
     toDate = toDate,

     uiDispatcher = Application.Current.MainWindow.Dispatcher, // for gui access on background thread
 };

 new Thread(() =>
 {
     context.BeginExecute<RealTimeProfilePoint>(qryUri, new AsyncCallback(realTimeCallBack), asyncState);
 })
 {
     IsBackground = true,
 }
 .Start();
于 2014-01-31T14:27:04.343 に答える