Многопоточные приложения в Visual Studio.NET. Разработка приложения, демонстрирующего многопоточность для одного процессора

 

 

 

 

 

 

 

 

 

 

 

 

 

 

ЛИТЕРАТУРА

 

1. Net. Сетевое программирование / А. Мунгале, В. Кумар, К. Нагел, Номан Лагари, Т. Паркер, Ш. Шивакумар, Э. Кровчик. М.: Лори, 2007. 416 с.
2. Райян Б. Основы разработки приложений на платформе Microsoft .NET Framework. Учебный курс Microsoft / Б. Райян, Т. Нортрап, Ш. Вилдермьюс. СПб.: Питер, 2007. 864 с.
3. Байдачный С. .Net Framework 2.0. Секреты создания Windows-приложений / С. Байдачный. М.: Солон, 2006. 520 с.
4. Шеферд Д. Программирование на Microsoft Visual C++.NET. Мастер-класс /Д. Шеферд. М.: Русская Редакция, 2005. 928 с.
5. Материалы сайта antichat.ru
6. Материалы сайта  csharpcoding.org

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

ПРИЛОЖЕНИЕ

 

Листинг приложения downloader

 

using System;

using System.Collections.Generic;

using System.Text;

using System.Threading;

using System.Net;

using System.IO;

using System.Diagnostics;

 

namespace Downloader

{

    class Program

    {

        //очередь адресов для закачки

        static Queue<string> URLs = new Queue<string>();

        //список скачанных страниц

        static List<string> HTMLs = new List<string>();

        //локер для очереди адресов

        static object URLlocker = new object();

        //локер для списка скачанных страниц

        static object HTMLlocker = new object();

        //очередь ошибок

        static Queue<Exception> exceptions = new Queue<Exception>();

 

        static void Main(string[] args)

        {

            Console.WriteLine("Введите количество  потоков для работы");

            int s = Convert.ToInt32(Console.ReadLine());

            var sw = new Stopwatch();//устанавливаем таймер и запускаем его

            sw.Start();

 

            URLs.Enqueue("http://google.com");

            URLs.Enqueue("http://yandex.ru");

            URLs.Enqueue("http://vorstu.ru");

            URLs.Enqueue("http://mail.ru");

            URLs.Enqueue("http://ru.akinator.com");

            URLs.Enqueue("http://really.ru");

            URLs.Enqueue("http://internat.ax3.net");

            URLs.Enqueue("http://kaspersky.ru");

 

            //создаем массив хендлеров, для контроля завершения потоков

            ManualResetEvent[] handles = new ManualResetEvent[s];

            //создаем и запускаем 3 потока

            for (int i = 0; i < s; i++)

            {

                handles[i] = new ManualResetEvent(false);

                (new Thread(new ParameterizedThreadStart(Download))).Start(handles[i]);

            }

            //ожидаем, пока все потоки отработают

            WaitHandle.WaitAll(handles);

            //проверяем ошибки, если были - выводим

            foreach (Exception ex in exceptions)

                Console.WriteLine(ex.Message);

            //сохраняем закачанные страницы  в файлы

            try

            {

                for (int i = 0; i < HTMLs.Count; i++)

                    File.WriteAllText(i + ".html", HTMLs[i]);

                Console.WriteLine(HTMLs.Count + " Файлов сохранено");

            }

            catch (Exception ex) { Console.WriteLine(ex); }

           

         

            sw.Stop();            //останавливаем таймер

   Console.WriteLine("Загрузка завершена за - "+sw.Elapsed.ToString()+" секунд ");

            Console.ReadLine();

        }

 

        public static void Download(object handle)

        {

            //будем крутить цикл, пока не  закончатся ULR в очереди

            while (true)

            try

            {

                string URL;

                //блокируем очередь URL и достаем оттуда один адрес

                lock (URLlocker)

                {

                    if (URLs.Count == 0)

                        break; //адресов больше нет, выходим из метода, завершаем поток

                    else

                        URL = URLs.Dequeue();

                }

                Console.WriteLine(URL + " - старт загрузки ...");

                //скачиваем страницу

                WebRequest request = WebRequest.Create(URL);

                HttpWebResponse response = (HttpWebResponse)request.GetResponse();

        string HTML = (new StreamReader(response.GetResponseStream())).ReadToEnd();

                //блокируем список скачанных страниц, и заносим туда свою страницу

                lock (HTMLlocker)

                    HTMLs.Add(HTML);

                //

                Console.WriteLine(URL + " - загружен (" + HTML.Length + " байт)");

            }

            catch (ThreadAbortException)

            {

                //это исключение возникает если  главный поток хочет завершить  приложение

                //просто выходим из цикла, и  завершаем выполнение

                break;

            }

            catch (Exception ex)

            {

                //в процессе работы возникло  исключение

                //заносим ошибку в очередь  ошибок, предварительно залочив  ее

                lock (exceptions)

                    exceptions.Enqueue(ex);

                //берем следующий URL

                continue;

            }

            //устанавливаем флажок хендла, что  бы сообщить главному потоку  о том, что мы отработали

            ((ManualResetEvent)handle).Set();

        }

    }

}