[Руководство] Многопоточность C#

[Sinyss]

Цитата: Сообщение от the-boxi Ну как бы это ужасный многопоток. Но для одного действия подойдет. А если действий много? То данные будут теряться. И лутче переменую счёта обьявить в потоке тоесть в процедуре int index_thread = main; main++;

А так у тебя будет много потоков которые делают одно и тоже....
а надо просто сделать

Цитата: object locker; lock(locker) { main++; }

[the-boxi]

Цитата: Сообщение от Sinyss А так у тебя будет много потоков которые делают одно и тоже.... а надо просто сделать

Ой да насчёт lock я забыл признаю.
Но object по моему надо указать глобально а не в процедуре.
И желательно же делать

object locker = new object();

Что бы выполнилось всё для создания...

[Sinyss]

Цитата: Сообщение от the-boxi Ой да насчёт lock я забыл признаю. Но object по моему надо указать глобально а не в процедуре. И желательно же делать object locker = new object(); Что бы выполнилось всё для создания...

Ну я псевдокодом, не помню уже точный синтаксис )
Да, locker глобальный.

[•theSaboteur•]

Yukikaze, Только что прочитал ваш код, что раньше сделать поленился..
Жесть.
1. К чему тут ртф я так и не понял
2. Зачем это писать еще и в файл?!
3. Элементарнеший вариант:
code

Пример собсно параллелит отправку пустых запросов, "подтверждает" работоспособность логами и ответами сервов.
2 текстбокса - tAddress(адреса), Received(для полученых данных. выводит айди потока кол-во уже выполненных запросов в этом потоке, пришедшие данные), LOG(сюда выводим инфо о расчетах)
1 батон - bSend
+ таймер - Timer(тут обновляем инфо в текстбоксе "Ресайвед". Прост если через (Бегин)Инуок обновлять ложится форма - слишком много "добра")
Кол-во потоков в переменной ThreadsCounter

        string RECEIVED = "";
        int ThreadsCounter=5; //предположим тут кол-во потоков.

        void bSendClickedHandler(object s, EventArgs args)
        {
            Queue<string> Addresses = new Queue<string>(tAddresses.Text.Split(new string[] { "\n" }, StringSplitOptions.RemoveEmptyEntries));
            int AddressesCount = Addresses.Count;
            int AddressesPerThread = AddressesCount / ThreadsCounter;
            while (AddressesPerThread * ThreadsCounter < AddressesCount)
            {
                ++AddressesPerThread;
            }
            int Line = 0;
            LOG.Text += "Addresses Count: " + AddressesCount.ToString();
            LOG.Text += "\r\n";
            LOG.Text += "Addresses per thread: " + AddressesPerThread.ToString();
            LOG.Text += "\r\n";
            for (int i = 0; i < ThreadsCounter; ++i)
            {
                Stack<string> AddressesPerCurrentThread = new Stack<string>();
                int lines = AddressesCount - Line; 
                if (lines > AddressesPerThread && i < ThreadsCounter-1) 
                    lines = AddressesPerThread;
                for (int j = 0; j < lines; ++j)
                {
                    AddressesPerCurrentThread.Push(Addresses.Dequeue());
                    ++Line;
                }
                LOG.Text += "New thread handles " + lines.ToString() + " addresses\r\n";
                Send(AddressesPerCurrentThread);
            }
        }

        void Send(Stack<string> addrs)
        {
            Thread th = new Thread(delegate()
                {
                    int counter=-1;
                loop:
                    try
                    {
                        HttpWebRequest req = HttpWebRequest.Create(addrs.Pop()) as HttpWebRequest;
                        HttpWebResponse res = req.GetResponse() as HttpWebResponse;
                        string rec = new StreamReader(res.GetResponseStream()).ReadToEnd();
                        RECEIVED += "\r\nThread: " + Thread.CurrentThread.ManagedThreadId.ToString() + "\r\nAddr: " + (++counter).ToString() + "\r\nData: " + rec+ "\r\n-----------------\r\n";
                        res.Close();
                    }
                    catch
                    {
                    }
                    if (addrs.Count > 0)
                        goto loop;
                    });
            th.Start();
        }
        private void Timer_Tick(object sender, EventArgs e)
        {
            this.Received.Text = RECEIVED;
        }

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

Минус - порой расчитывает так, что часть потоков обрабатывает по несколько адресов, остальная часть - ничего (видно на скрине).
Ну да не страшно.

[Yukikaze]

•theSaboteur•, я знаю, что там бред, поэтому пользуюсь таким вариантом:

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Net;
using System.IO;
using System.Threading;

namespace ParallelForEach
{
    public partial class Form1 : Form
    {
        readonly ParallelOptions o = new ParallelOptions();
        private Thread t;
        public Form1()
        {
            InitializeComponent();
        }
        private void button1_Click(object sender, EventArgs e)
        {
            t = new Thread(s_w);
            t.Start();
        }

        string send_POST(string url, string post)
        {
            string Response_POST = "", StrNewValue;
            try
            {
                HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);
                req.Method = "POST";
                req.Proxy = new WebProxy("127.0.0.1", 8888);
                req.ContentType = "application/x-www-form-urlencoded";
                StrNewValue = post;
                req.ContentLength = StrNewValue.Length;
                StreamWriter Soup = new StreamWriter(req.GetRequestStream(), System.Text.Encoding.ASCII);
                Soup.Write(StrNewValue);
                Soup.Close();
                StreamReader stin3 = new StreamReader(req.GetResponse().GetResponseStream());
                Response_POST = stin3.ReadToEnd();
                stin3.Close();
            }
            catch { }
            return Response_POST;
        }

        private void s_w()
        {
            o.MaxDegreeOfParallelism =  Convert.ToInt32(numericUpDown1.Value);
            Parallel.ForEach(GetLine(), o,
                line => send_POST("http://www.yandex.ru/" + line, ""));
        }

        IEnumerable<string> GetLine()
        {
            string[] line = null;
            if (richTextBox1.InvokeRequired)
            {
                richTextBox1.Invoke(
                    new Action(() =>                                
                    {                                
                        line = richTextBox1.Text.Split('\n');                                 
                    }                                
                    ));
            }
            else
        line = richTextBox1.Text.Split('\n');
            return line;
        }
    }
}

[Gamer1912]

так и не понял остальные способы, но способ автора приспособил для id:auth

main++;
string fake = mas[main - 1].Split(':');
send_POST("http://server.ru", "id=" + fake[0] + "auth=" + fake[1]);
send_POST("http://server2.ru", "id=" + fake[0] + "auth=" + fake[1]);

[Sinyss]

Цитата: Сообщение от Gamer1912 так и не понял остальные способы, но способ автора приспособил для id:auth main++; string fake = mas[main - 1].Split(':'); send_POST("http://server.ru", "id=" + fake[0] + "auth=" + fake[1]); send_POST("http://server2.ru", "id=" + fake[0] + "auth=" + fake[1]);

ну и где тут многопоточность? обычная линейная программа...

[Gamer1912]

Sinyss, Это же лишь кусок кода!
Вот получается весь код

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

namespace Threads
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        int main;
        string[] mas;
        private void button1_Click(object sender, EventArgs e)
        {
            mas = richTextBox1.Text.Split('\n');
            main = 0;
            int s = Convert.ToInt32(numericUpDown1.Value);
            Thread[] thread = new Thread[s];
            for (int i = 0; i < s; i++)
            {
                Thread thr = new Thread(new ThreadStart(s_w));
                thread[i] = thr;
                Thread.Sleep(55);
                thread[i].Start();
            }
        }

        public string send_POST(string url, string post)
        {
            string Response_POST = "", StrNewValue;
            try
            {
                HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);
                req.Method = "POST";
                req.Proxy = null;
                req.ContentType = "application/x-www-form-urlencoded";
                StrNewValue = post;
                req.ContentLength = StrNewValue.Length;
                StreamWriter Soup = new StreamWriter(req.GetRequestStream(), System.Text.Encoding.ASCII);
                Soup.Write(StrNewValue);
                Soup.Close();
                StreamReader stin3 = new StreamReader(req.GetResponse().GetResponseStream());
                Response_POST = stin3.ReadToEnd();
                stin3.Close();
            }
            catch { }
            return Response_POST;
        }

        private void s_w()
        {
            try
            {
                 main++;
                 string[] fake = mas[main - 1].Split(':');
                 send_POST("http://server.ru", "id=" + fake[0] + "auth=" + fake[1]);
                 send_POST("http://server2.ru", "id=" + fake[0] + "auth=" + fake[1]);
            }
            catch { }
        }
    }
}

Полностью авторский код, с добавлением тех самых строк, что я написал выше!