C# Многопоточность

[thezoke]

Вот нормальный урок многопоточности в отличие от этого

Если будут вопросы пишите, особы я не тестировал.
Если что-то не так будет пишите.

Для начала добавим элемент.
У меня вот так выглядит.

[Ссылки могут видеть только зарегистрированные пользователи. ]
Далее добавить директивы using

using System;
using System.Text;
using System.Windows.Forms;
using System.IO;
using System.Net;
using System.Threading;

Объявим переменные

Thread[] threads; // Обьявляем массив потоков
        int i = 0; // позиция
        String[] lines = null; // Массив сайтов
        Object locks = new Object(); // Object для lock

Добавим такой код на кнопку "старт".
Почти весь код прокомментирован так что я здесь объяснять не буду.

lines = richTextBox1.Lines;
            i = 0;
            if (lines.Length < 1) 
            {
                MessageBox.Show(this, "Слишком мало сайтов, попробуйте снова!", "Threads Example", MessageBoxButtons.OK, MessageBoxIcon.Stop);
                return;
                // завершаем если строк меньше 1
            }
            threads = new Thread[(int)numericUpDown1.Value]; 
            for (int q = 0; q < threads.Length; q++)
            {
                threads[q] = new Thread(main); // поток будет запускать функцию main
                threads[q].Start(); // запускаем
              }
             new Thread(waitth).Start();

Добавим две функций. Для отправки get запроса и ожидание завершения работы потоков.

private void waitth()
        {
            for (int q = 0; q < threads.Length; q++)
            {
                threads[i].Join(); // ожидаем когда потом закончится
            }
            MessageBox.Show(this, "Работа завершена!", "Threads Example", MessageBoxButtons.OK, MessageBoxIcon.Stop);   
        }
        public string get(string _url, CookieCollection Cooks) // функция для отправки get запроса
        {
            try
            {
                HttpWebRequest webRequest = (HttpWebRequest)WebRequest.Create(_url);
                webRequest.CookieContainer = new CookieContainer();
                webRequest.AllowAutoRedirect = false; // автоматическая переадресация
                webRequest.Timeout = 30000; // время ожидания загрузки страницы
                webRequest.UserAgent = "Mozilla/5.0 (Windows; U; Windows NT 5.1; ru; rv:1.9.0.19) Gecko/2010031422 Firefox/3.0.19";
                
                if (Cooks != null)
                    webRequest.CookieContainer.Add(Cooks);
                using (HttpWebResponse webResponse = (HttpWebResponse)webRequest.GetResponse())
                {
                    webResponse.Cookies = webRequest.CookieContainer.GetCookies(webRequest.RequestUri);
                    if (webResponse.Cookies != null)
                        Cooks.Add(webResponse.Cookies);
                    string dataContent = new StreamReader(webResponse.GetResponseStream(), Encoding.GetEncoding(1251)).ReadToEnd();
                    string end = webResponse.Headers.ToString();
                    return end + dataContent;
                }
            }
            catch
            {
                return null; // если была ошибка в загрузке страницы возвращаем null
            }
        }

На кнопку стоп

for (int q = 0; q < threads.Length; q++)
            {
                threads[i].Abort(); // прерываем поток
            }

Ну и главная функция

private void main()
        {
            while (true)
            {
                string url;
                lock (locks) // доступ только с одного потока, блокирует доступ с остальных и они в процессе ожидания.
                {
                    if (i > lines.Length - 1) // проверяем не весь ли массив прошли
                    {
                        break; // останавливаем поток
                    }
                    url = lines[i]; // здесь понятно
                    i++; // всё равно что i = i +1; или i += 1;
                    if (!url.Contains("http://"))  // проверяем, если в линке нету http:// начинаем цикл заново. url.Contains("http://") == False - тоже самое
                    {
                        continue; // завершаем потом
                    }
                }
                CookieCollection Cooks = new CookieCollection(); // создаём куки менеджер, автоматическии обрабатытает куки
                get(url, Cooks); // отправляем get запрос

            }
        }

[sergiktipok]

многопоток не работает!доходят только два запроса!

[the-boxi]

Слишком много всего, можно всё гараздо легче... Ты не пробовал всё в Одну процедуру хотябы засунуть?

new Thread(delegate(){
//код который выполнять потоку
}).Start();

[thezoke]

Пробовал, так можно ещё и в одну строку написать.

[Sinyss]

Цитата: Сообщение от thezoke Пробовал, так можно ещё и в одну строку написать.

Любой код можно в 1 строку написать, но нужно ли?

[thezoke]

Цитата: Сообщение от WebHoster А в чем, собственно, разница?

стиль программирования другой

[thezoke]

Цитата: Сообщение от rif009 Самая частая ошибка при программирование на .net надо закрывать потоки webResponse.Close(); так же для всех стреам и тд

Урок был многопоточности, а не отправки get запроса.
Там вроде автоматический закрывает, я точно не помню.

[JLeGioH]

Открою секрет для тех кто незнает)

Цитата: threads = new Thread[(int)numericUpDown1.Value]; for (int q = 0; q < threads.Length; q++) { threads[q] = new Thread(main); // поток будет запускать функцию main threads[q].Start(); // запускаем }

равно на все 100%
єтому:

Цитата: for (int q = 0; q < (int)numericUpDown1.Value; q++) { Thread threads = new Thread(main); // поток будет запускать функцию main threads.Start(); // запускаем }

Каждый раз будет создаваться другой поток и первый никуда не денется)
+ Метод МАЙН будет для каждого потока свой индивидуальный(клавное парвильно потокобезопасность сделать)

(Сори за ошЫбки))

[the-boxi]

Ну вообще проше всего вызывать потоки таким методом:

for (int q = 0; q < (int)numericUpDown1.Value; q++)
new Thread(delegate(){Выполняемый код}).Start();

Либо не делегатом и писать код внутри, а ссылаться на процедуру

for (int q = 0; q < (int)numericUpDown1.Value; q++)
new Thread(процедура).Start();

И контролировать поток внутри будет проще всего. То есть сделать его бекграундом, и вызывать обрывание самого же себя после окончания работы.

[Sinyss]

Цитата: Сообщение от the-boxi И контролировать поток внутри будет проще всего. То есть сделать его бекграундом, и вызывать обрывание самого же себя после окончания работы.

Не всегда потоки могут знать когда им выходить.

[the-boxi]

Цитата: Сообщение от Sinyss Не всегда потоки могут знать когда им выходить.

Ну если не знаешь как работать с потоками, лучше туда не лезть. Но а вообще для этого существует библиотека майкрософта.
Метод Abort - Вызывает исключение ThreadAbortException в вызвавшем его потоке для того, чтобы начать процесс завершения потока. Вызов данного метода обычно завершает поток.
И для этого в конце процедуры пишешь

Thread.CurrentThread.Abort();

[Sinyss]

Цитата: Сообщение от the-boxi Ну если не знаешь как работать с потоками, лучше туда не лезть. Но а вообще для этого существует библиотека майкрософта. Метод Abort - Вызывает исключение ThreadAbortException в вызвавшем его потоке для того, чтобы начать процесс завершения потока. Вызов данного метода обычно завершает поток. И для этого в конце процедуры пишешь Thread.CurrentThread.Abort();

Я умею работать с потоками.
Я имел в виду что потоки могут быть вечными(целенаправленно, например ожидание события)... Или ты можешь послать в поток такую задачу, которая никогда не выполнится(не намеренно), но будет работать правильно... Потому лучше потоки делать с глобальной областью видимости(для класса).