task-parallel-library

7Nhiệt

2Trả lời

Làm cách nào để hạn chế số lượng Tác vụ đang hoạt động chạy qua Thư viện tác vụ song song?

Tôi có một số ConcurrentQueue chứa Action (System.Action). Mỗi hành động trong hàng đợi này cần phải chạy (cần được gọi bằng cách sử dụng lời gọi). Khi hàng đợi không trống => hành động cần được gọi =

6Nhiệt

2Trả lời

Parallel.ForEach bị đình trệ khi tích hợp với BlockingCollection

tôi thông qua thực hiện của tôi song song/người tiêu dùng dựa trên các mã trong this question class ParallelConsumer<T> : IDisposable { private readonly int _maxParallel; private readonly A

13Nhiệt

1Trả lời

UnsafeQueueUserWorkItem và chính xác "không tuyên truyền ngăn xếp cuộc gọi" nghĩa là gì?

Tôi đang đọc và tìm hiểu về ThreadScheduler và các bài viết xung quanh Công việc và đi qua chức năng ThreadPool.UnsafeQueueUserWorkItem được sử dụng ở một trong số MSDN examples về Trình tự ThreadSche

5Nhiệt

1Trả lời

Sử dụng đúng ParallelOptions, TaskCreationOptions và Task.Factory.StartNew?

Xin gợi ý cho phương pháp nào là phù hợp (nếu có) cho chính xác và sử dụng hiệu quả ParallelOptions, TaskCreationOptions và Task.Factory.StartNew (() =>. private void NeedToUse_MaxDegreeOfParallelism_

5Nhiệt

1Trả lời

Tôi nên truyền bá ngoại lệ nhiệm vụ từ tác vụ tiếp tục trong .NET 4.0 như thế nào?

Tôi có đoạn mã sau: innerExceptions = dbconnByServer .AsParallel() .WithDegreeOfParallelism(dbconnByServer.Count) // A stream of groups of server connections proceeding in parallel per

12Nhiệt

2Trả lời

Tạo một nhiệm vụ với nhịp tim

Tôi muốn chạy một Task có "heartbeat" tiếp tục chạy tại một khoảng thời gian cụ thể cho đến khi tác vụ hoàn tất. Tôi đang nghĩ đến một phương pháp mở rộng như thế này sẽ làm việc tốt: public static as

31Nhiệt

2Trả lời

Task.Factory.StartNew vs Task.Factory.FromAsync

Giả sử chúng ta có phương thức liên kết I/O (chẳng hạn như phương thức tạo cuộc gọi DB). Phương thức này có thể chạy cả trong đồng bộ và không đồng bộ. Đó là, Sync: IOMethod() Async: BeginIOMethod()

7Nhiệt

2Trả lời

Thử lại chính sách trong ITargetBlock <TInput>

Tôi cần giới thiệu chính sách thử lại cho quy trình làm việc. Hãy nói rằng có 3 khối được kết nối theo cách như vậy: var executionOptions = new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism =

52Nhiệt

2Trả lời

Thực hiện hoàn thành chính xác một khối có thể thử lại

Teaser: các bạn, câu hỏi này không phải là về cách triển khai chính sách thử lại. Đó là về việc hoàn thành chính xác khối TPL Dataflow. Câu hỏi này chủ yếu là sự tiếp nối câu hỏi trước của tôi Retry p

7Nhiệt

1Trả lời

Phương thức mở rộng triển khai WebRequest.GetResponseAsync với sự hỗ trợ cho CancellationToken

Ý tưởng ở đây rất đơn giản, nhưng việc triển khai có một số sắc thái thú vị. Đây là chữ ký của phương pháp mở rộng mà tôi muốn triển khai trong .NET 4. public static Task<WebResponse> GetResponseAsync