Làm cách nào để chạy các truy vấn NHibenate không đồng bộ?

Question

Một cách để tăng khả năng mở rộng của ứng dụng máy chủ là chạy hoạt động liên kết IO (đọc tệp, ổ cắm, yêu cầu web, yêu cầu cơ sở dữ liệu, v.v.) không đồng bộ. Điều này không có nghĩa là chạy chúng trong ThreadPool mà sẽ chỉ chặn các luồng trong khi thao tác đang được thực hiện. Cách chính xác là sử dụng API không đồng bộ (BeginRead, BeginGetResponse, BeginExecuteReader, v.v.). Vấn đề cũng được mô tả trong cuốn sách CLR vi C#.

Dưới đây là một số bài viết về asynchronous queries in Linq to SQL.

Có cách nào để thực thi truy vấn Nhibernate một cách đồng bộ không? Điều gì về Linq để NHibernate?

Cảm ơn bạn, Andrey

Answer 1

Thật không may, không. NHibernate không phơi bày việc thực thi nội bộ của lệnh thực thi theo cách mà L2S thực hiện.

Bạn sẽ phải sử dụng trình tạo luồng hoặc tạo bản vá cho NH để thêm hỗ trợ truy vấn không đồng bộ. Điều đó sẽ rất được hoan nghênh bởi cộng đồng và sẽ tạo nên một bài tập tốt đẹp (nhưng nó không tầm thường chút nào)

Answer 2

Lưu ý rằng các cuộc gọi cơ sở dữ liệu không đồng bộ KHÔNG ngụ ý khả năng mở rộng tổng thể tốt hơn. Tôi khuyên bạn nên đọc bài viết "Should my database calls be Asynchronous?" để có phân tích chuyên sâu. Dưới đây là một trích dẫn từ bài viết rằng:

Một tôn trọng DB kiến ​​trúc sư/Web đã đi xa hơn khi nói:
Đối với cơ sở dữ liệu ứng dụng sử dụng các hoạt động async để giảm số lượng các chủ đề chặn trên máy chủ web được hầu như luôn luôn là hoàn toàn lãng phí thời gian. Máy chủ web nhỏ có thể dễ dàng xử lý theo cách yêu cầu chặn đồng thời hơn cơ sở dữ liệu của bạn back-end có thể xử lý đồng thời. Thay vào đó, hãy đảm bảo rằng các cuộc gọi dịch vụ của bạn có giá rẻ tại cơ sở dữ liệu và giới hạn số lượng đồng thời thực hiện các yêu cầu đến số mà bạn đã thử nghiệm để làm việc một cách chính xác và tối đa hóa thông lượng giao dịch tổng thể .

Answer 3

Mặc dù vẫn không có hỗ trợ cho truy vấn không đồng bộ trong NH, bạn vẫn có thể khắc phục một phần tác động không mong muốn của các cuộc gọi db chạy dài (chạy dài) từ chuỗi yêu cầu.

Điều bạn muốn là chia Threadpool giữa các hoạt động ngắn và dài hạn. Tất nhiên điều này là không thể với việc thực hiện thực tế của Threadpool và TPL nhưng bạn có thể giúp mình khá eassilly bằng cách viết hàng đợi của riêng bạn Sản xuất/tiêu dùng với các mặt hàng awaitable và tùy chỉnh concurency.

hãy có một cái nhìn vào ví dụ tôi đã đặt lại với nhau: https://gist.github.com/3746240

Mã được sao chép/dán từ cuốn sách tuyệt vời "C# 5.0 in a Nutshell: Các tham chiếu Definitive" bởi Joseph Albahari và Ben Albahari với sửa đổi được thực hiện bởi tôi khiến cho trình lên lịch tạo ra các chuỗi công việc chuyên dụng cho các mục proccesing.

Answer 4

nhiều cuộc gọi async thể được viết lại với Futures

var footask = QueryFooAsync(); 
var bartask = QueryBarAsync(); 
var baztask = QueryBazAsync(); 

var foos = await footask; 
var bars = await bartask; 
var baz = await baztask; 

// do something with foos, bars, baz 

có thể được thay thế bằng

var foos = session.Query<Foo>().....ToFuture(); 
var bars = session.Query<Bar>().....ToFuture(); 
var baz = session.Query<Bazes>().....ToFutureValue(); 

await Task.Factory.StartNew(() => var ignored = baz.Value) // await the results 

// do something with foos, bars, baz 

này thậm chí còn có lợi ích trên mã async rằng thời gian khứ hồi chỉ được thanh toán một lần thay vì 3 lần .