1

В начале выполняется данный кусок кода:

        List<Thread> listOfThreads = new List<Thread>(50);// 50 взято для примера
        for (int i = 0; i < 50; i++) 
        {
            listOfThreads.Add(new Thread(new ParameterizedThreadStart(voidForThreads)));
            ParametersForThread parameters = new ParametersForThread()
            {
                // Некоторые параметры
            };
            listOfThreads[i].Start(parameters);
        }

После:

        foreach (var thread in listOfThreads)
        {
            thread.Join();
        }

Код отрабатывает, метод, где создаётся 50 потоков, гордо возвращает null, а потом срабатывает breakPoint внутри voidForThreads. 50 раз подряд...

Если я правильно понимаю причину, то thread.Join(); вызывается раньше, чем потоки начинают свою работу. Чем такой недуг можно вылечить? Или причина и вовсе в другом?

UPD: Вот метод voidForThreads:

    private async Task voidForThreads(object obj)
    {
        ParametersForThread parameters = (ParametersForThread)obj;

        var request = new HttpRequestMessage(HttpMethod.Post, "site");

        var getOrderRequest = new GetOrderRequest()
        {
            OrderIDArray = parameters.PackOrders,
        };


        string text = new XMLConverter().ConvertObjectToXMLString(typeof(GetOrderRequest), getOrderRequest);
        request.Content = new StringContent(text);

        var client = parameters._clientFactory.CreateClient();

        HttpResponseMessage response = null;

        try
        {
            response = await client.SendAsync(request: request);
        }
        catch
        {
            // тут немного другая логика, но в блок catch в данном методе я
            // ещё ни разу не попадал - не думаю, что проблема в нём
            throw new NotImplementedException(); 
        }

        // Метод отработал верно - я проверял
        GetOrderResponse result = (GetOrderResponse)new XMLConverter().ConvertXMLStringToObject(typeof(GetOrderResponse), await response.Content.ReadAsStringAsync());

        // private GetOrderResponseOrderArray[][] ResultList - приватное поле, объявлено заранее
        ResultList[parameters.NumberInList] = new GetOrderResponseOrderArray[result.OrderArray.Length];
        for (int i = 0; i < result.OrderArray.Length; i++)
        {
            // Логика немного упрощена - мне не весь массив результатов нужен, поэтому здесь
            // поштучное копирование нужных полей
            ResultList[parameters.numberInList][i] = result.OrderArray[i];
        }
    }

И также класс ParametersForThread:

    private class ParametersForThread
    {
        public string[] PackOrders { get; set; }
        public IHttpClientFactory _clientFactory { get; set; }
        public int NumberInList { get; set; }
    }
12
  • Подскажите, а какую именно задачу вы решаете в данном коде? Запустить 50 потоков и продолжить выполнение программы, когда все отработают, верно я понял?
    – aepot
    25 мар 2020 в 19:18
  • @aepot Да, верно. Мне нужно 50 раз осуществить вызов сторонних API. Не хотелось бы в один поток ждать 50 ответов
    – Anatoly
    25 мар 2020 в 19:20
  • а зачем их в список добавлять? Может это лишнее? Может просто 50 запустить, а потом дождаться, когда все закончат? Я для того чтобы правильный ответ написать спрашиваю.
    – aepot
    25 мар 2020 в 19:22
  • 2
    @Anatoly У вас voidForThreads уже async Task, поэтому вам надо делать не список Thread-ов, а список Task-ов. Почитайте про Task и async/await. Всё гораздо проще можно сделать, чем у вас, но для начала почитайте доки и примеры. Например вот: docs.microsoft.com/ru-ru/dotnet/api/…
    – CrazyElf
    26 мар 2020 в 10:20
  • 2
    Асинхронный метод может вернуть управление до того, как закончится сам. Ничего удивительного, что ваши треды рапортуют о том, что отработали, хотя сама работа еще не завершена.
    – tym32167
    26 мар 2020 в 13:16

1 ответ 1

2

Отдельная благодарность пользователям @aepot и @CrazyElf.

Код ниже хоть и не даёт ответа на вопрос "Почему thread.Join() отработал раньше старта работы потоков?", - но решает мою проблему:

public class MainClass
{
    private GetOrderResponseOrderArray[][] ResultArray { get; set; }

    // Конструкция List<string[]> listOfPackOrders вызвана ограничениями используемых API
    public async Task MainMethod(IHttpClientFactory _clientFactory, List<string[]> listOfPackOrders)
    {
        if (_clientFactory is null)
        {
            throw new ArgumentNullException(nameof(_clientFactory));
        }

        if (listOfPackOrders is null)
        {
            throw new ArgumentNullException(nameof(listOfPackOrders));
        }

        ResultArray = new GetOrderResponseOrderArray[listOfPackOrders.Count][];
        Task[] arrayOfTasks = new Task[listOfPackOrders.Count];
        for (int i = 0; i < listOfPackOrders.Count; i++)
        {
            ParametersForThread parameters = new ParametersForThread()
            {
                NumberInList = i,
                PackOrders = listOfPackOrders[i],
                _clientFactory = _clientFactory
            };
            arrayOfTasks[i] = Task.Run(async () => { await TaskForTaskArray(parameters); });
        }
        Task.WaitAll(arrayOfTasks);

        // Дальнейшая работа с ResultArray
    }


    private async Task TaskForTaskArray(ParametersForThread parameters)
    {
        var request = new HttpRequestMessage(HttpMethod.Post, "site");

        var getOrderTransactionsRequest = new GetOrderTransactionsRequest()
        {
            OrderIDArray = parameters.PackOrders;
        };

        string text = new XMLConverter().ConvertObjectToXMLString(typeof(GetOrderTransactionsRequest), getOrderTransactionsRequest);
        request.Content = new StringContent(text);

        var client = parameters._clientFactory.CreateClient();
        HttpResponseMessage response = null;

            try
            {
                response = await client.SendAsync(request: request);
            }
            catch
            {
                // тут немного другая логика, но в блок catch в данном методе я
                // ещё ни разу не попадал - не думаю, что проблема в нём
                throw new NotImplementedException(); 
            } 

        GetOrderResponse result = (GetOrderResponse)new XMLConverter().ConvertXMLStringToObject(typeof(GetOrderResponse), await response.Content.ReadAsStringAsync());

        ResultList[parameters.NumberInList] = new GetOrderResponseOrderArray[result.OrderArray.Length];
        for (int i = 0; i < result.OrderArray.Length; i++)
        {
            // Логика немного упрощена - мне не весь массив результатов нужен, поэтому здесь
            // поштучное копирование нужных полей
            ResultList[parameters.numberInList][i] = result.OrderArray[i];
        }
    }

    private class ParametersForThread
    {
        public string[] PackOrders { get; set; }
        public IHttpClientFactory _clientFactory { get; set; }
        public int NumberInList { get; set; }
    }
}

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.