Как я могу запустить запросы NHibenate асинхронно?

Question

Одним из способов увеличения масштабируемости серверного приложения является асинхронное выполнение операции ввода-вывода (чтение файлов, сокетов, веб-запросов, запросов к базе данных и т. Д.). Это не значит запускать их в ThreadPool, который будет просто блокировать потоки во время выполнения операции. Правильный способ - использовать асинхронный API (BeginRead, BeginGetResponse, BeginExecuteReader и т. Д.). Проблема хорошо описана в книге CLR vi C#.

Ниже приведена статья о asynchronous queries in Linq to SQL.

Возможны ли какие-либо способы выполнения запроса Nhibernate asynchonously? Что относительно Linq для NHibernate?

Спасибо, Андрей

Answer 1

К сожалению, нет. NHibernate не предоставляет внутреннюю реализацию выполнения команды в способе L2S.

Вам нужно будет использовать threadpool ИЛИ создать патч для NH, чтобы добавить поддержку асинхронного запроса. Это было бы очень желанным для сообщества и сделало бы приятное упражнение (но это совсем не так)

Answer 2

Обратите внимание, что вызовы асинхронной базы данных не подразумевают лучшей общей масштабируемости сами по себе. Я рекомендую прочитать статью «Should my database calls be Asynchronous?» для углубленного анализа. Вот цитата из этой статьи:

Один уважаемый DB/Веб-архитектор пошел так далеко, чтобы сказать:
Для баз данных приложений, использующих операции асинхронное для уменьшить количество заблокированных потоков на веб-сервере почти всегда полная потеря времени. Небольшой веб-сервер может легко обрабатывать способ больше одновременных запросов на блокировку, чем , ваша база данных базы данных может обрабатывать одновременно. Вместо того, чтобы убедиться, что ваши звонки сервис дешевы в базе данных , и ограничить число одновременно выполняющихся запросов к числа, которые вы проверили, чтобы правильно работать и максимизировать общую пропускную способность транзакций.

Answer 3

Хотя по-прежнему нет поддержки для асинхронных запросов в NH, вы все же можете частично преодолеть некоторые нежелательные эффекты запуска (длительных) вызовов db из потока запросов.

Что вы хотите, так это разделить пространство потоков между краткосрочными и долгосрочными операциями. Конечно, это невозможно с фактической реализацией Threadpool и TPL, но вы можете очень помочь себе, написав свою собственную очередь Producer/Consumer с ожидаемыми статьями и настроенной совпадением.

Пожалуйста, посмотрите на пример я соединили: https://gist.github.com/3746240

Код копирования/вставки из большой книги «C# 5.0 в двух словах: The Definitive Reference» Джозеф Albahari и Бен Albahari с модификацией сделано мной заставляя планировщик создавать посвященные рабочие потоки для обработки элементов.

Answer 4

несколько асинхронных вызовов могут быть переписаны с фьючерсами

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 

можно заменить

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 

это даже имеет преимущество над асинхронным кодом, туда и обратно время выплачивается только один раз, а не в 3 раза ,