Аватар для anonimus
2184 / 1255 / 143
Регистрация: 28.04.2010
Сообщений: 4,592
.NET 4.x

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

13.03.2013, 10:42. Показов 2676. Ответов 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
6102 / 4958 / 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
6102 / 4958 / 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
Ответ Создать тему
Опции темы

Новые блоги и статьи
[golang] Алгоритм «Хак Госпера»
alhaos 17.05.2026
Алгоритм «Хак Госпера» Хак Госпера (Gosper's Hack) — алгоритм нахождения следующего по величине числа с тем же количеством установленных бит. Придуман Биллом Госпером в 1970-х, опубликован в. . .
Рисование бинарного древа до 6-го колена на js, svg.
russiannick 17.05.2026
<svg width="335" height="240" viewBox="0 0 335 240" fill="#e5e1bb"> <style> <!]> </ style> <g id="bush"> </ g> </ svg> function fn(){ let rost;/ / высота древа let xx=165,yy=210,w=256;
FSharp: interface of module
DevAlt 16.05.2026
Интерфейс модуля F# позволяет управлять доступностью членов, содержащихся в реализации модуля. По-умолчанию все члены модуля доступны: module Foo let x = 10 let boo () = printfn "boo" . . .
Хитросплетение родственных связей пантеона греческих богов.
russiannick 14.05.2026
Однооконник, позволяющий узреть и изучить отдельных героев древней Греции. <!DOCTYPE html> <html lang="ru"> <head> <meta charset="UTF-8"> <meta http-equiv="X-UA-Compatible". . .
[golang] Угол между стрелками часов
alhaos 12.05.2026
По заданным значениям часа и минуты необходимо определить значение меньшего угла между стрелками аналогового циферблата часов. import "math" func angleClock(hour int, minutes int) float64 { . . .
Debian 13: Установка Lazarus QT5
ВитГо 09.05.2026
Эта инструкция моя компиляция инструкций volvo https:/ / www. cyberforum. ru/ blogs/ 203668/ 10753. html и его же старой инструкции по установке Lazarus с gtk2. . .
Нейросеть на алгоритме "эстафета хвоста" как перспектива.
Hrethgir 06.05.2026
На десерт, когда запущу сервер. Статья тут https:/ / habr. com/ ru/ articles/ 1030914/ . Автор я сам, нейросеть только помогает в вопросах которые мне не известны - не знаю людей которые знали-бы. . .
Асинхронный приём данных из COM-порта
Argus19 01.05.2026
Асинхронный приём данных из COM-порта Купил на aliexpress термопринтер QR701. Он оказался странным. Поключил к Arduino Nano. Был очень удивлён. Наотрез отказывается печатать русские буквы. Чтобы. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru