Форум программистов, компьютерный форум, киберфорум
C# .NET
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
 
Рейтинг 4.85/13: Рейтинг темы: голосов - 13, средняя оценка - 4.85
 Аватар для anonimus
2184 / 1255 / 143
Регистрация: 28.04.2010
Сообщений: 4,592
.NET 4.x

Работа с потоками

13.03.2013, 10:42. Показов 2554. Ответов 29
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
У меня приложение через заданный интервал (в таймере) отправляет запрос на сайт и парсит ответ, при отправке запросов приложение подвисает, нужно прикручивать потоки, но что будет если поток еще будет выполняться а таймер запустит еще один, а мне бы этого не хотелось, нельзя отправлять следующий запрос пока мы не пропарсили ответ от предыдущего. Как быть в данном случаи?
1
Лучшие ответы (1)
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
13.03.2013, 10:42
Ответы с готовыми решениями:

Работа с потоками
Ребята, помогите. На C# программирую недавно, про потоки слышу впервые. Подскажите как это можно реализовать в VS2005. 1. Warcraft....

Работа с потоками
Доброе время суток подскажите пож как реализовать : "Шарики. Координаты заданного количества шариков изменяются на случайную величину по...

работа с потоками
При работе с методом выдает ошибку: "Недопустимая операция в нескольких потоках: попытка доступа к элементу управления...

29
 Аватар для anonimus
2184 / 1255 / 143
Регистрация: 28.04.2010
Сообщений: 4,592
13.03.2013, 14:22  [ТС]
Студворк — интернет-сервис помощи студентам
Urety, с потоками тоже вариант (его уже обсуждали выше)
C#
1
if (!resEvent.IsSet)
мне кажется лучше сделать так
C#
1
2
3
thread = new Thread(ThreadFunction);
thread.Start(моя процедура);
thread.Join();
т.е. что бы не началось выполнение пока не закончил выполнения др. поток
1
774 / 554 / 80
Регистрация: 03.07.2011
Сообщений: 1,020
13.03.2013, 14:29
Цитата Сообщение от anonimus Посмотреть сообщение
а таймер запустит еще один, а мне бы этого не хотелось, нельзя отправлять следующий запрос пока мы не пропарсили ответ от предыдущего. Как быть в данном случаи?
anonimus, Могу такой способ предложить
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
  public void send()
        {
            HttpWebRequest reQ = (HttpWebRequest)HttpWebRequest.Create("https://www.cyberforum.ru/csharp-net/thread807250.html");
            reQ.Method = "POST";
            reQ.Host = "www.cyberforum.ru";
            reQ.ServicePoint.Expect100Continue = false;
            reQ.KeepAlive = false;
            reQ.AllowAutoRedirect = true;
            reQ.Headers.Add(HttpRequestHeader.CacheControl, "no-cache");
            reQ.Accept = "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8";
            reQ.Headers.Add(HttpRequestHeader.AcceptCharset, "windows-1251,utf-8;q=0.7,*;q=0.7");
            reQ.Headers.Add(HttpRequestHeader.AcceptLanguage, "ru-ru,ru;q=0.8,en-us;q=0.5,en;q=0.3");
            reQ.UserAgent = "Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 6.1; Trident/5.0; SLCC2; .NET CLR 2.0.50727; .NET CLR 3.5.30729; .NET CLR 3.0.30729; Media Center PC 6.0; .NET4.0C; .NET4.0E; InfoPath.2)";
          
            reQ.BeginGetRequestStream(new AsyncCallback(GetRequestStreamCallback1), reQ);
          
        }
 
        public void GetRequestStreamCallback1(IAsyncResult asynchronousResult)
        {
            try
            {
                HttpWebRequest request = (HttpWebRequest)asynchronousResult.AsyncState;
                Stream postStream = request.EndGetRequestStream(asynchronousResult);
 
                postStream.Close();
                request.BeginGetResponse(new AsyncCallback(GetResponseCallback1), request);
            }
            catch (WebException exc)
            {
                Console.WriteLine("Network Error: " + exc.Message +
                                  "\nStatus code: " + exc.Status);
 
                      Return();
 
            }
            catch (ProtocolViolationException exc)
            {
                Console.WriteLine("Protocol Error: " + exc.Message);
            }
            catch (UriFormatException exc)
            {
                Console.WriteLine("URI Format Error: " + exc.Message);
            }
            catch (NotSupportedException exc)
            {
                Console.WriteLine("Unknown Protocol: " + exc.Message);
            }
            catch (IOException exc)
            {
                Console.WriteLine("I/O Error: " + exc.Message);
            }
            catch (System.Security.SecurityException exc)
            {
                Console.WriteLine("Security Exception: " + exc.Message);
            }
            catch (InvalidOperationException exc)
            {
                Console.WriteLine("Invalid Operation: " + exc.Message);
            }
        }
 
        void Return()
        {
            Thread.Sleep(1000); //спим секунду и по новой 
            send();
        }
        public void GetResponseCallback1(IAsyncResult asynchronousResult)
        {
            HttpWebRequest request = (HttpWebRequest)asynchronousResult.AsyncState;
            HttpWebResponse response = (HttpWebResponse)request.EndGetResponse(asynchronousResult);
            Stream streamResponse = response.GetResponseStream();
            StreamReader streamRead = new StreamReader(streamResponse,Encoding.Default);
            string responseString = streamRead.ReadToEnd();
 
            Console.WriteLine(responseString);
 
            streamResponse.Close();
            streamRead.Close();
            response.Close();
 
            Return();
        }
Добавлено через 50 секунд
loro, В эксепшины хорошо завернул ))
2
Master of Orion
Эксперт .NET
 Аватар для Psilon
6101 / 4957 / 905
Регистрация: 10.07.2011
Сообщений: 14,522
Записей в блоге: 5
13.03.2013, 14:36
Вот есть хороший пример в инете:
Давайте попробуем переписать в новом виде наш второй пример, который одновременно получает результаты от трех веб-страниц и асинхронно записывает результат в файл:
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
public static async void AsyncVersion2()
{
    Stopwatch sw = Stopwatch.StartNew();
    var urls = new string[] {"http://rsdn.ru", "http://gotdotnet.ru", 
        "http://blogs.msdn.com"};
    var tasks = (from url in urls 
                let webRequest = WebRequest.Create(url)
                select new {Url = url, Response = webRequest.GetResponseAsync()})
                .ToList();
    var data = await TaskEx.WhenAll(tasks.Select(t=>t.Response));
    var sb = new StringBuilder();
    foreach(var s in tasks)
    {
        sb.AppendFormat("{0}: {1}, elapsed {2}ms. Thread Id: {3}", s.Url, 
            s.Response.Result.ContentLength,
            sw.ElapsedMilliseconds, Thread.CurrentThread.ManagedThreadId)
            .AppendLine();
    }
    var outputText = sb.ToString();
    Console.WriteLine("Web request results: {0}", outputText);
            
    using (var fs = new FileStream("d:\\results.txt", FileMode.Create,
            FileAccess.Write, FileShare.Write))
    {
        await
        fs.WriteAsync(UnicodeEncoding.Default.GetBytes(outputText), 0,
                        UnicodeEncoding.Default.GetByteCount(outputText));
    }
            
}
Вот это уже действительно интересно! Мы получили полностью асинхронный код, но при этом он не выглядит так, будто над ним несколько ночей трудилось стадо индусов (а ведь асинхронный код подобной сложности именно так и выглядит). Он понятен и читается аналогично синхронному! (Если кто не верит, то пусть попробует переписать этот код в классическом APM стиле).

Итак, что мы имеем? Мы имеем штуку, которой действительно удобно пользоваться без боязни отстрелить себе ногу. Кроме того, даже не вдаваясь в серьезные дебри, более или менее понятно, как этим делом пользоваться (мда, хотя к именам придется привыкнуть). И самое интересное, что это далеко не вся функциональность. Я не рассказывал о контекстах синхронизации и о том, как это дело можно здорово использовать с потоком пользовательского интерфейса, о том, что такое TAP (Task-based Asynchronous Pattern), не говорил о том, что все новые асинхронные методы, которые я использовал являются методами расширения и вы можете их добавлять самостоятельно сколько угодно, да и не вдавался в дебри реализации… Но об этом всем, как-нибудь в другой раз! А сегодня, я вам предлагаю, просто скачать эту штуку и попробовать ее самостоятельно!

(Чуть не забыл, вот url, чтобы вы долго его не искали: msdn.com/vstudio/async)
2
Заблокирован
13.03.2013, 14:38
Цитата Сообщение от anonimus Посмотреть сообщение
Urety, с потоками тоже вариант (его уже обсуждали выше)
C#
1
if (!resEvent.IsSet)
мне кажется лучше сделать так
C#
1
2
3
thread = new Thread(ThreadFunction);
thread.Start(моя процедура);
thread.Join();
т.е. что бы не началось выполнение пока не закончил выполнения др. поток
Если ты сделаешь Join(), то зависнет главнй поток.
Новое выполнение не начнется пока не будет установлен сигнал от ManualResetEventSlim.
0
774 / 554 / 80
Регистрация: 03.07.2011
Сообщений: 1,020
13.03.2013, 14:55
Подправил свой вариант
Кликните здесь для просмотра всего текста
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
103
class CookieDemo
{
    static void Main(string[] args)
    {
 
        send();
        Console.ReadLine();
 
 
    }
    static public void send()
    {
        HttpWebRequest reQ = (HttpWebRequest)HttpWebRequest.Create("https://www.cyberforum.ru/csharp-net/thread807250.html");
        reQ.Method = "POST";
        reQ.Host = "www.cyberforum.ru";
        reQ.ServicePoint.Expect100Continue = false;
        reQ.KeepAlive = false;
        reQ.AllowAutoRedirect = true;
        reQ.Headers.Add(HttpRequestHeader.CacheControl, "no-cache");
        reQ.Accept = "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8";
        reQ.Headers.Add(HttpRequestHeader.AcceptCharset, "windows-1251,utf-8;q=0.7,*;q=0.7");
        reQ.Headers.Add(HttpRequestHeader.AcceptLanguage, "ru-ru,ru;q=0.8,en-us;q=0.5,en;q=0.3");
        reQ.UserAgent = "Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 6.1; Trident/5.0; SLCC2; .NET CLR 2.0.50727; .NET CLR 3.5.30729; .NET CLR 3.0.30729; Media Center PC 6.0; .NET4.0C; .NET4.0E; InfoPath.2)";
 
        reQ.BeginGetRequestStream(new AsyncCallback(GetRequestStreamCallback1), reQ);
 
    }
 
    static public void GetRequestStreamCallback1(IAsyncResult asynchronousResult)
    {
        try
        {
            HttpWebRequest request = (HttpWebRequest)asynchronousResult.AsyncState;
            Stream postStream = request.EndGetRequestStream(asynchronousResult);
 
            postStream.Close();
            request.BeginGetResponse(new AsyncCallback(GetResponseCallback1), request);
        }
        catch (WebException exc)
        {
            Console.WriteLine("Network Error: " + exc.Message +
                              "\nStatus code: " + exc.Status);
 
            Return(false);
 
        }
        catch (ProtocolViolationException exc)
        {
            Console.WriteLine("Protocol Error: " + exc.Message);
        }
        catch (UriFormatException exc)
        {
            Console.WriteLine("URI Format Error: " + exc.Message);
        }
        catch (NotSupportedException exc)
        {
            Console.WriteLine("Unknown Protocol: " + exc.Message);
        }
        catch (IOException exc)
        {
            Console.WriteLine("I/O Error: " + exc.Message);
        }
        catch (System.Security.SecurityException exc)
        {
            Console.WriteLine("Security Exception: " + exc.Message);
        }
        catch (InvalidOperationException exc)
        {
            Console.WriteLine("Invalid Operation: " + exc.Message);
        }
    }
 
    static void Return(bool IsSuccessful)
    {
        if (IsSuccessful)
        {
            Thread.Sleep(2000); //спим 2 секунды и по новой
            send();
        }
        else Console.WriteLine("Fail");
    }
    static public void GetResponseCallback1(IAsyncResult asynchronousResult)
    {
        HttpWebRequest request = (HttpWebRequest)asynchronousResult.AsyncState;
        HttpWebResponse response = (HttpWebResponse)request.EndGetResponse(asynchronousResult);
        Stream streamResponse = response.GetResponseStream();
        StreamReader streamRead = new StreamReader(streamResponse, Encoding.Default);
        string responseString = streamRead.ReadToEnd();
 
        Console.WriteLine(responseString);
 
 
        streamResponse.Close();
        streamRead.Close();
        response.Close();
 
        if (asynchronousResult.IsCompleted)
        {
            Return(true);
        }
        else Console.WriteLine("Brrrr...");
    }
}
2
Master of Orion
Эксперт .NET
 Аватар для Psilon
6101 / 4957 / 905
Регистрация: 10.07.2011
Сообщений: 14,522
Записей в блоге: 5
13.03.2013, 15:07
вот такой пример:
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
using System;
using System.Threading;
using System.Timers;
using System.Windows.Forms;
using Timer = System.Timers.Timer;
 
namespace WindowsFormsApplication5
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
 
        private void Form1_Load(object sender, EventArgs e)
        {
            timer.Elapsed += Foo;
            timer.Start();
        }
 
        private Timer timer = new Timer(200);
        private Random r = new Random();
        private string mutexname = "localmutex";
 
        private void Foo(object sender, ElapsedEventArgs eventArgs)
        {
            bool createdNew;
            var m = new Mutex(true, mutexname, out createdNew);
            if (!createdNew)
            {
                BeginInvoke(new Action(() => textBox1.Text += "Tryed to send but another thread is running\r\n"));
                return;
            }
            var t = r.Next(1000, 4000);
            BeginInvoke(new Action(() => textBox1.Text += string.Format("I'm sleeping for {0} ms\r\n", t)));
            Thread.Sleep(t);
            m.Dispose();
        }
    }
}
2
 Аватар для anonimus
2184 / 1255 / 143
Регистрация: 28.04.2010
Сообщений: 4,592
13.03.2013, 15:33  [ТС]
Цитата Сообщение от Urety Посмотреть сообщение
то зависнет главнй поток.
а с чего он зависнит, я ж вызываю Join() для вновь созданного потока

Добавлено через 4 минуты
стыдно, но я вообще не понял о чем тут речь
https://www.cyberforum.ru/post4248441.html
0
Заблокирован
13.03.2013, 15:58
Vitall, завернул в стиле Java программера. Ну думаю, капелька пота тут появилась

Добавлено через 8 минут
короче мне пишет какую фигню, а правила читать не хочу, поэтому поблагодарю n-ое кол-во раз.

Добавлено через 2 минуты
всем спасибо.. все свободны
0
Заблокирован
13.03.2013, 16:07
Цитата Сообщение от anonimus Посмотреть сообщение
а с чего он зависнит, я ж вызываю Join() для вновь созданного потока

Добавлено через 4 минуты
стыдно, но я вообще не понял о чем тут речь
https://www.cyberforum.ru/post4248441.html
Речь тут о том, что вы блокируете свой главный поток, из которого работает приложение: http://msdn.microsoft.com/ru-r... 7b1ct.aspx

Т.е. смысл делать многопоточность, если блокировать главный поток, пока фоновый(или приоритетный) не завершится (приложение зависнет).
Более того, так у вас остается рабочий поток, и вы сможете прервать уже выполняющийся запрос в любой момент, и начать новый, где я приводил пример как его прервать из главного потока.
0
 Аватар для anonimus
2184 / 1255 / 143
Регистрация: 28.04.2010
Сообщений: 4,592
14.03.2013, 09:42  [ТС]
пришел домой посмотрел в код и понял что если буду делать асинхронные вызовы придется значительно код переписать, к тому же с этими call back функциями не передать в нее параметр не принять от нее (либо можно но я не знаю как). Сделал через потоки, работает хорошо, так что всем спасибо.
P.S. что бы потоки не мешали друг другу воспользовался lock
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
14.03.2013, 09:42
Помогаю со студенческими работами здесь

Работа с потоками...
Понимаю, что тема проезжена и не раз, однако спрошу:-[: Есть консольное приложение, оно занимается подсчетом сообщений. По запросу оно...

Работа с потоками
Здравствуйте. Проблема заключается в следующем, в параллельном потоке мне нужно чтобы label1 созданный в основном потоке, изменялся....

Работа с байтовыми потоками
Доброго времени суток. Столкнулся с такой проблемой , имеется файл(песня mp3) необходим считать из него скажем первые 10 байт и потом...

Работа с потоками
Помогите начинающему программисту!!! Нужно написать программу в которой есть два дочерних потока. В главном потоке интовой переменной...

Работа с потоками
В общем, сделал рекурсивное удаление файлов и папок в несколько потоков, но вылетают эксепшены что файл уже удален. Можно ли как-то...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
30
Ответ Создать тему
Новые блоги и статьи
PhpStorm 2025.3: WSL Terminal всегда стартует в ~
and_y87 14.12.2025
PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .
Access
VikBal 11.12.2025
Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.
Новый ноутбук
volvo 07.12.2025
Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro
Музыка, написанная Искусственным Интеллектом
volvo 04.12.2025
Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .
От async/await к виртуальным потокам в Python
IndentationError 23.11.2025
Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .
Поиск "дружественных имён" СОМ портов
Argus19 22.11.2025
Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .
Сколько Государство потратило денег на меня, обеспечивая инсулином.
Programma_Boinc 20.11.2025
Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha
Etyuhibosecyu 20.11.2025
Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .
Мысли в слух
kumehtar 18.11.2025
Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .
Создание Single Page Application на фреймах
krapotkin 16.11.2025
Статья исключительно для начинающих. Подходы оригинальностью не блещут. В век Веб все очень привыкли к дизайну Single-Page-Application . Быстренько разберем подход "на фреймах". Мы делаем одну. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru