2

编辑：在所有事件完成之前，问题已经转移到结束。

我在使用 fo-dicom 库确定任务时遇到问题。

请求是 sendasync，但响应在事件委托中。

我的示例代码发送一个请求（查找研究），得到一个响应并产生另一个请求（查找上述研究的系列），该请求也有一个响应。最终我需要发送一个移动请求，然后排队一个延迟的验证任务。

我确定我的任务/异步逻辑有一个问题。

示例代码

要做的事情列表，但 Task.WhenAll(t)在所有任务对象事件完成之前结束。

在触发事件之前如何保持任务？

       List<Task<DicomMoveResult>> t = new List<Task<DicomMoveResult>>();
         foreach (var item in dbSet)
         {
            t.Add(DicomMove(item));
         }
         var x = await Task.WhenAll(t);
         Console.WriteLine("Finished");

工作方法

      private static async Task<DicomMoveResult> DicomMove(DicomMoveRequest request)
            {
                DicomMoveResult r = new DicomMoveResult() { Request = request };

                var client = new DicomClient();

                var cfindStudy = DicomCFindRequest.CreateStudyQuery(accession: request.Accession);

                cfindStudy.OnResponseReceived += async (DicomCFindRequest rq, DicomCFindResponse rp) =>
                {

                    if (rp.Status.State == DicomState.Pending)
                    {
                        if (rp.HasDataset)
                        {
                            var studyInstanceUID = rp.Dataset.Get<string>(DicomTag.StudyInstanceUID);
                            r.StudyId = studyInstanceUID;

                            var cfindSeries = DicomCFindRequest.CreateSeriesQuery(studyInstanceUID);
                            cfindSeries.OnResponseReceived += (DicomCFindRequest srq, DicomCFindResponse srp) =>
                            {
                                if (srp.Status.State == DicomState.Pending)
                                {
                                    if (srp.HasDataset)
                                    {
                                        var seriesInstanceUID = srp.Dataset.Get<string>(DicomTag.SeriesInstanceUID);
                                        r.SeriesId.Add(seriesInstanceUID);

                                    }
                                }


                            };

                            client.AddRequest(cfindSeries);
                            await client.SendAsync(request.PACSIP, request.PACSPort, false, request.CallingAE, request.PACSAE);

                        }

                    }


                };

                client.AddRequest(cfindStudy);
                await client.SendAsync(request.PACSIP, request.PACSPort, false, request.CallingAE, request.PACSAE);

                return r;
            }
4

0 回答 0