Как из асинхронного метода получить объект?

@Soft17 · Регистрация: 15.01.2017

Студворк — интернет-сервис помощи студентам

Вопрос
Как из асинхронного метода получить объект?

Используется
- Microsoft.EntityFrameworkCore;
- Microsoft.EntityFrameworkCore.SqlServer.

Описание
Я пробую сделать аналогичный проект.
Ссылка на проект - link // github.com

Я пробую повторить метод - `GetPosts(int index, int pageSize, string tag = null)`
Я хочу сделать аналогичный асинхронный метод с произвольным запросом.
Запрос например: `query = query.Where(p => p.ContactName.Contains("Maria"));`

Я пробую сделать простой метод:

C#
1
2
3
4
5
6
7
8
9
10
11
12
public Customer GetCustomers()
{
    Customer result = new Customer();
 
    using (var context = ContextFactory.CreateDbContext(ConnectionString))
    {
      var query = context.Customers.AsQueryable();                
      query = query.Where(p => p.ContactName.Contains("Maria")); //
      result = query as Customer;
    }
    return result;
}

Результат в строке `query = query.Where(p => p.ContactName.Contains("Maria"));` смотри картинку.

Вопрос
Как такой метод сделать асинхронным с таким же или другим запросом?

Попытка номер - 1. Результат - не работает

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
public Task<Customer> GetCustomersTask()
        {
            // Customer result = new Customer();
 
            var result = new TaskCompletionSource<Customer>();
 
            using (var context = ContextFactory.CreateDbContext(ConnectionString))
            {
                Task.Run(() =>
                {
                    var query = context.Customers.AsQueryable();
                    query = query.Where(p => p.ContactName == "Maria");
 
                    result.SetResult(query as Customer);
                }
                );
            }
            return result.Task;
        }

@Soft17 · 26.03.2020, 18:44 **[ТС]**

- Приложение: ConsoleAppCore - .NET Core. Console
- Приложение: DBRepository - .NET Standart.

@Рядовой · 26.03.2020, 20:46

Soft17,

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
    public Task<Customer> GetCustomersAsync()
    {
        Customer result = null;
        await Task.Run(() =>
        {
            using (var context = ContextFactory.CreateDbContext(ConnectionString))
            {
                var query = context.Customers.AsQueryable();
                query = query.Where(p => p.ContactName.Contains("Maria")); //
                result = query as Customer;
            }
        });
        return result;
    }

@Soft17 · 26.03.2020, 22:14 **[ТС]**

Рядовой,

Добавил "async", т.к. без "async" получаю ошибки.
Ошибки:
1. Не удается неявно преобразовать тип "Models.Customer" в "System.Threading.Tasks.Task<Models.Cust omer>".
2. Оператор await можно использовать только в методах с модификатором async.
Consider marking this method with the 'async' modifier and changing its return type to 'Task<Task<Customer>>'.

Результат.

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
public async Task<Customer> GetCustomersTask()
        {
            try
            {
                Customer result = null;
                await Task.Run(() =>
                {
                    using (var context = ContextFactory.CreateDbContext(ConnectionString))
                    {
                        var query = context.Customers.AsQueryable();
                        query = query.Where(p => p.ContactName.Contains("Maria")); //
                    result = query as Customer;
                    }
                });
                return result;
            }
            catch (Exception ex)
            {
                string str_Mes = ex.Message;
 
                throw;
            }
            
        }

Делаю отладку.
Прихожу в блок:

C#
1
2
3
4
5
6
7
8
9
 await Task.Run(() =>
                {
                    using (var context = ContextFactory.CreateDbContext(ConnectionString))
                    {
                        var query = context.Customers.AsQueryable();
                        query = query.Where(p => p.ContactName.Contains("Maria")); //
                    result = query as Customer;
                    }
                });

Нажимаю "дальше" (F11).
Отладка прерывается.

@Рядовой · 26.03.2020, 22:29

Soft17, да, async забыл.
Она не прерывается, просто асинхронно стал выполняться блок внутри Task.Run. Когда результат будет готов строка сама переключится на

return result;

@Soft17 · 26.03.2020, 22:38 **[ТС]**

Сообщение от Рядовой

Soft17, да, async забыл.
Она не прерывается, просто асинхронно стал выполняться блок внутри Task.Run. Когда результат будет готов строка сама переключится на

Понял...
Только в результате запроса я должен получить две строки из таблицы.
Как мне их получить?

@Soft17 · 26.03.2020, 22:48 **[ТС]**

Сообщение от Рядовой

Когда результат будет готов строка сама переключится на
return result;

см. предыдущее сообщение..
Вроде код не переключается на

C#
1
return result;

@Рядовой · 26.03.2020, 22:54

Soft17, можете вернуть
- List<Customer>
- Tuple<Customer, Customer>
- class foo
{
Customer c1;
Customer c2;
}

Добавлено через 4 минуты

Сообщение от Soft17

Вроде код не переключается на

Может надолго заходит/виснет/ зацикливается - я не знаю. Отдебажте ваш код внутри Task.Run без асинхронных запросов.

@Soft17 · 26.03.2020, 22:56 **[ТС]**

Сообщение от Рядовой

можете вернуть
- List<Customer>
- Tuple<Customer, Customer>
- class foo
{
Customer c1;
Customer c2;
}

Я с таким не сталкивался... Буду разбираться...
Если вам не сложно, не могли бы вы по подробнее описать данное решение..

@Soft17 · 26.03.2020, 23:16 **[ТС]**

Сообщение от Рядовой

Может надолго заходит/виснет/ зацикливается - я не знаю. Отдебажте ваш код внутри Task.Run без асинхронных запросов.

Результат

@Рядовой · 27.03.2020, 00:00

Soft17, а как сам GetCustomersTask вызываете? Надеюсь с await?

@Soft17 · 27.03.2020, 21:48 **[ТС]**

Сообщение от Рядовой

Soft17, а как сам GetCustomersTask вызываете? Надеюсь с await?

Метод "GetCustomersTask" вызывается методом "GetCustomersTask1_Test".
После данного вашего сообщения я сделал:
- добавил в метод "GetCustomersTask1_Test" слово "async";
- добавил в строку "var customerList = _iCustomerRepository.GetCustomersTask(); " слово "await".

Результат:

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
public async void GetCustomersTask1_Test()
        {
 
            SettingsService settingsService = new SettingsService();
            Settings settings = new Settings();
 
            // Получить строку подключения
            settings = settingsService.ReadFilfeT();
            string connectionString = settings.ConnectionString;
 
            IRepositoryContextFactory _iRepositoryContextFactory = new RepositoryContextFactory();
            ICustomerRepositoryAnsw _iCustomerRepository = new CustomerRepositoryAnsw(connectionString, _iRepositoryContextFactory);
          
 
            #region Run the test
            var customerList = await _iCustomerRepository.GetCustomersTask();
            string test = "";
            #endregion
 
            #region Result
            //int countRowInSettings_bl = settings_bl.Count;
 
            //Assert.AreEqual(3, countRowInSettings_bl);
            #endregion
        }

Повторяется результат сообщения "11"
Т.е.
Нажимаю "дальше" (F11).
Отладка прерывается.

Я правильно понял ваше сообщение?

@Рядовой · 28.03.2020, 10:12

Soft17, написано все правильно.

Сообщение от Soft17

Отладка прерывается.

Что это значит? Завершается программа, или программа работает дальше как обычно, но метод ничего не возращает?
В catch заходит?
Поставьте брейкпоинт на выходе из метода. Зайдет он туда?
Зайдите в отладку асинхронного метода, поставьте брейкпоинт на эту строку

var query = context.Customers.AsQueryable();

@Soft17 · 28.03.2020, 11:09 **[ТС]**

Сообщение от Рядовой

Что это значит? Завершается программа, или программа работает дальше как обычно, но метод ничего не возращает?
В catch заходит?
Поставьте брейкпоинт на выходе из метода. Зайдет он туда?
Зайдите в отладку асинхронного метода, поставьте брейкпоинт на эту строку

Происходит как на gif.

Прилагаю весь проект.
Состав:
- ConsoleAppCore\
- .vs\
- DBRepository\
- Models\
- NUnitTestConsoleCore\
- [dbo].[Customers]_CREATE TABLE.sql
- [dbo].[Customers]_DataTable.sql
- ConsoleAppCore_01.sln

@kolorotur · 28.03.2020, 12:43

Сообщение от Soft17

C#
1
await Task.Run(() =>

Зачем вручную создавать таски, которые потом блокировать (читай — нерациональное расходование дорогостоящих ресурсов), если у EF Core есть асинхронные методы из коробки?

C#
1
2
3
4
5
6
7
8
public async Task<Customer> GetCustomers()
{
    using (var context = ContextFactory.CreateDbContext(ConnectionString))
    {
      var query = context.Where(p => p.ContactName.Contains("Maria"));              
      return await query.FirstOrDefaultAsync();
    }
}

@Soft17 · 28.03.2020, 13:21 **[ТС]**

Сообщение от kolorotur

Зачем вручную создавать таски, которые потом блокировать (читай — нерациональное расходование дорогостоящих ресурсов), если у EF Core есть асинхронные методы из коробки?

Кааак?!

Где мне найти результат (см. картинку)?

Может у кого-нибудь есть возможность на примере проекта - 14 на прямую посмотреть что я делаю не так?
Мне кажется там на две минуты делов...

@kolorotur · 28.03.2020, 14:00

Сообщение от Soft17

Кааак?!
Где мне найти результат (см. картинку)?

Если у вас асинхронные методы, то делайте всю цепь вызовов асинхронной.

CustomerRepositoryAnsw

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
public async Task<Customer> GetCustomersTask()
{
    try
    {
        using (var context = ContextFactory.CreateDbContext(ConnectionString))
        {
            var query = context.Customers.Where(p => p.ContactName.Contains("Maria"));
            return await query.FirstOrDefaultAsync();
        }
    }
    catch (Exception ex)
    {
        string str_Mes = ex.Message;
 
        throw;
    }
}

TestAnsw.cs

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
using System;
using System.Collections.Generic;
using System.Text;
using System.Linq;
using System.Threading.Tasks;
 
// 
using NUnit.Framework;
using Microsoft.VisualStudio.TestTools.UnitTesting;
 
//
using ConsoleApp;
using ConsoleApp.Model;
using DBRepository.Interfaces;
using DBRepository.Repositories;
using DBRepository.Factories;
 
namespace ConsoleAppCore
{
    // NUnit тестирование 
    // пишем классы с атрибутом [TestFixture] 
    // пишем методы с атрибутом [Test] 
    [TestFixture]
    public class TestAnsw
    {
        public TestAnsw()
        {
 
        }
 
        public Task TestMain()
        {
            return GetCustomersTask1_Test();
            // GetCustomers();
        }
 
 
        /// <summary>
        /// 
        /// </summary>
        public void GetCustomersTask_Test()
        {
            SettingsService settingsService = new SettingsService();
            Settings settings = new Settings();
 
            // Получить строку подключения
            settings = settingsService.ReadFilfeT();
            string connectionString = settings.ConnectionString;
 
            IRepositoryContextFactory _iRepositoryContextFactory = new RepositoryContextFactory();
            ICustomerRepositoryAnsw _iCustomerRepository = new CustomerRepositoryAnsw(connectionString, _iRepositoryContextFactory);
            
            var customerList = _iCustomerRepository.GetCustomersTask();
            
        }
 
        /// <summary>
        /// 
        /// 
        /// GetCustomersTask
        /// </summary>
        public async Task GetCustomersTask1_Test()
        {
            SettingsService settingsService = new SettingsService();
            Settings settings = new Settings();
 
            // Получить строку подключения
            settings = settingsService.ReadFilfeT();
            string connectionString = settings.ConnectionString;
 
            IRepositoryContextFactory _iRepositoryContextFactory = new RepositoryContextFactory();
            ICustomerRepositoryAnsw _iCustomerRepository = new CustomerRepositoryAnsw(connectionString, _iRepositoryContextFactory);
            
            var customer = await _iCustomerRepository.GetCustomersTask();
            string test = "";
            
        }
 
 
        /// <summary>
        /// 
        /// 
        /// 
        /// </summary>
        public void GetCustomers()
        {
            SettingsService settingsService = new SettingsService();
            Settings settings = new Settings();
 
            // Получить строку подключения
            settings = settingsService.ReadFilfeT();
            string connectionString = settings.ConnectionString;
 
            IRepositoryContextFactory _iRepositoryContextFactory = new RepositoryContextFactory();
            ICustomerRepositoryAnsw _iCustomerRepository = new CustomerRepositoryAnsw(connectionString, _iRepositoryContextFactory);
            
            var customerList = _iCustomerRepository.GetCustomers();
            string test = "";            
        }
 
    }
}

Program.cs

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
using ConsoleApp;
using ConsoleApp.Model;
using System;
using System.Threading.Tasks;
 
namespace ConsoleAppCore
{
    class Program
    {
        static async Task Main(string[] args)
        {
            //   Console.WriteLine("Hello World!");
 
            await TestMain();
        }
 
        #region *** TestMain *** 
        static public Task TestMain()
        {            
            TestAnsw testAnsw = new TestAnsw();
            return testAnsw.TestMain();
        }        
        #endregion
 
    }
}

@Soft17 · 28.03.2020, 15:49 **[ТС]**

kolorotur,
С асинхронностью разобрались...

А как мне получить результат выполнения запроса?
В запросе я получаю две записи.
Как забрать из метода "GetCustomersTask()" две записи?

В методе

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
public async Task<Customer> GetCustomersTask()
{
    try
    {
        using (var context = ContextFactory.CreateDbContext(ConnectionString))
        {
            var query = context.Customers.Where(p => p.ContactName.Contains("Maria"));
            return await query.FirstOrDefaultAsync();
        }
    }
    catch (Exception ex)
    {
        string str_Mes = ex.Message;
 
        throw;
    }
}

В строке "var query = context.Customers.Where(p => p.ContactName.Contains("Maria"));" я получаю две записи...
В строке "return await query.FirstOrDefaultAsync();" я получаю первую запись... вроде...

@kolorotur · 28.03.2020, 16:10

Сообщение от Soft17

Как забрать из метода "GetCustomersTask()" две записи?

Измените тип возвращаемого значения с одного экземпляра Customer на несколько — например, в списке:

C#
1
Task<List<Customer>>

В коде метода вместо FirstOrDefaultAsync возвращайте ToListAsync

@Soft17 · 28.03.2020, 16:39 **[ТС]**

kolorotur,
Вроде работает...

Сделал так

C#
1
2
3
4
5
6
7
8
9
10
11
12
        public async Task<List<Customer>> GetCustomersTask3()
        {
 
            using (var context = ContextFactory.CreateDbContext(ConnectionString))
            {
                var query = context.Customers.AsQueryable();
                query = query.Where(p => p.ContactName.Contains("Maria")); //
 
                return await query.ToListAsync();
            }
 
        }

Вопросы:
1. Почему проход по строчкам "var query = context.Customers.AsQueryable();" и "return await query.ToListAsync();" выполняется два раза?
2. Дохожу до строки 164, нажимаю два раза F11 и только тогда отладка продолжается. Почему так происходит?

Новые блоги и статьи Все статьи Все блоги /
Модель микоризы: классовый агентный подход 3 anaschu 06.01.2026 aa0a7f55b50dd51c5ec569d2d10c54f6/ O1rJuneU_ls https:/ / vkvideo. ru/ video-115721503_456239114	Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ФедосеевПавел 06.01.2026 Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ВВЕДЕНИЕ Введу сокращения: аналоговый ПИД — ПИД регулятор с управляющим выходом в виде числа в диапазоне от 0% до. . .	Модель микоризы: классовый агентный подход 2 anaschu 06.01.2026 репозиторий https:/ / github. com/ shumilovas/ fungi ветка по-частям. коммит Create переделка под биомассу. txt вход sc, но sm считается внутри мицелия. кстати, обьем тоже должен там считаться. . . .	Расчёт токов в цепи постоянного тока igorrr37 05.01.2026 / * Дана цепь постоянного тока с сопротивлениями и напряжениями. Надо найти токи в ветвях. Программа составляет систему уравнений по 1 и 2 законам Кирхгофа и решает её. Последовательность действий:. . .
Новый CodeBlocs. Версия 25.03 palva 04.01.2026 Оказывается, недавно вышла новая версия CodeBlocks за номером 25. 03. Когда-то давно я возился с только что вышедшей тогда версией 20. 03. С тех пор я давно снёс всё с компьютера и забыл. Теперь. . .	Модель микоризы: классовый агентный подход anaschu 02.01.2026 Раньше это было два гриба и бактерия. Теперь три гриба, растение. И на уровне агентов добавится между грибами или бактериями взаимодействий. До того я пробовал подход через многомерные массивы,. . .	Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост. Programma_Boinc 28.12.2025 Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост. Налог на собак: https:/ / ********/ gallery/ V06K53e Финансовый отчет в Excel: https:/ / ********/ gallery/ bKBkQFf Пост отсюда. . .	Кто-нибудь знает, где можно бесплатно получить настольный компьютер или ноутбук? США. Programma_Boinc 26.12.2025 Нашел на реддите интересную статью под названием Anyone know where to get a free Desktop or Laptop? Ниже её машинный перевод. После долгих разбирательств я наконец-то вернула себе. . .

Как из асинхронного метода получить объект?

Решение

Решение

@Soft17 5 / 5 / 3 Регистрация: 15.01.2017 Сообщений: 690
	26.03.2020, 18:44 [ТС]
	- Приложение: ConsoleAppCore - .NET Core. Console - Приложение: DBRepository - .NET Standart. 0

@Рядовой 1524 / 914 / 329 Регистрация: 17.05.2015 Сообщений: 3,438
	27.03.2020, 00:00
	Soft17, а как сам GetCustomersTask вызываете? Надеюсь с await? 1