Форум программистов, компьютерный форум, киберфорум
Наши страницы

С++ для начинающих

Войти
Регистрация
Восстановить пароль
 
 
Gooman
10 / 10 / 0
Регистрация: 03.10.2010
Сообщений: 350
#1

Работа с потоками идет не так, как надо. Почему? - C++

23.09.2012, 11:07. Просмотров 999. Ответов 26
Метки нет (Все метки)

Есть вот такая вот программа моя. Она запускает потоки сортировки массива и его вывода с разными приоритетами. Но даже если приоритет потока вывода HIGHEST, а сортировки IDLE, то массив выводится все равно отсортированным. Вы не подскажите, почему? Программу в Visual Studio писал.
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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
#include "stdafx.h"
#include "iostream"
#include "windows.h"
#include "stdlib.h"
#include "time.h"
#include "fstream"
#include "winbase.h"
using namespace std;
 
const int ARR_LEN = 86; // длина массивa
int *arr = new int[ARR_LEN];
//ofstream outFile;
 
void CreateTwoProcesses(DWORD priority1, DWORD priority2);  // создает 2 процесса с указанными приоритетами
char* PrToStr(DWORD priority);                              // преобразует переменную DWORD в строку char
void PrintCurrentTime(char *str);                           // выводит текущее время
void insert_sorting(int *a, int count);                     // сортировка массива вставками
void PrintTimeDiff(SYSTEMTIME start, SYSTEMTIME end);       // рассчитывает разницу между интеравалами времени
void CreateTwoThreads(DWORD pr1, DWORD pr2);                // создание двух потоков
DWORD WINAPI print (void *parg);                            // поток печати
DWORD WINAPI sort (void *parg);                             // поток сортировки
 
int _tmain(int argc, _TCHAR* argv[])
{
    CreateTwoThreads(THREAD_PRIORITY_NORMAL, THREAD_PRIORITY_NORMAL);
    CreateTwoThreads(THREAD_PRIORITY_IDLE, THREAD_PRIORITY_HIGHEST);
    CreateTwoThreads(THREAD_PRIORITY_IDLE, THREAD_PRIORITY_IDLE);
    CreateTwoThreads(THREAD_PRIORITY_NORMAL, THREAD_PRIORITY_IDLE);
    system("pause");
    
    return 0;
}
 
//---------------------------------------------------------------------------
void PrintCurrentTime(char *str)
{
   SYSTEMTIME time;
   GetSystemTime(&time); // начало выполнения
   cout << str << time.wMinute << "m:"
               << time.wSecond << "s:"
               << time.wMilliseconds << "ms\n";
}
//---------------------------------------------------------------------------
void PrintTimeDiff(SYSTEMTIME start, SYSTEMTIME end)
{
   FILETIME      ft1, ft2;
   LARGE_INTEGER li1, li2;
   LARGE_INTEGER delta;        // t2-t1
 
   // вычисляем разницу во времени
   SystemTimeToFileTime(&start, &ft1);
   SystemTimeToFileTime(&end, &ft2);
   li1.LowPart  = ft1.dwLowDateTime;
   li1.HighPart = ft1.dwHighDateTime;
   li2.LowPart  = ft2.dwLowDateTime;
   li2.HighPart = ft2.dwHighDateTime;
   // разница
   delta.QuadPart = li2.QuadPart - li1.QuadPart;
   cout << "Vremya sortirovki: " << delta.QuadPart/10000 << "ms" << endl;
}
//---------------------------------------------------------------------------
char *PrToStr(DWORD priority)
{
   char *s;
   switch (priority) {
      case THREAD_PRIORITY_IDLE   : s = strdup("THREAD_PRIORITY_IDLE");   break;
      case THREAD_PRIORITY_NORMAL : s = strdup("THREAD_PRIORITY_NORMAL"); break;
      case THREAD_PRIORITY_HIGHEST: s = strdup("THREAD_PRIORITY_HIGHEST");break;
      default: s = strdup("");
   }
   return s;
}
//---------------------------------------------------------------------------
void CreateTwoThreads(DWORD pr1, DWORD pr2)
{
   HANDLE print_thread;       // поток печати
   HANDLE sort_thread;        // поток сортировки
   DWORD  print_id;
   DWORD  sort_id;
   DWORD  exitcode;
   SYSTEMTIME start_time, end_time;  // время начала и конца работы для определения разницы
 
   GetSystemTime(&start_time);
 
   // заполняем массив
   for (int i = 0; i < ARR_LEN; i++)
      arr[i] = rand() % 10000;
 
   PrintCurrentTime("Nachalo raboty: ");
 
   // создаём поток сортировки
   sort_thread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)sort, NULL, CREATE_SUSPENDED, &sort_id);
   cout << "Sozdan potok sort. Prioritet: " << PrToStr(pr1) << endl;
   //outFile << "Sozdan potok sort. Prioritet: " << PrToStr(pr1) << endl;
   
   // создаём поток печати
   print_thread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)print, NULL, CREATE_SUSPENDED, &print_id);
   cout << "Sozdan potok print. Prioritet: " << PrToStr(pr2) << endl;
   //outFile << "Sozdan potok print. Prioritet: " << PrToStr(pr2) << endl;
 
   // устанавливаем приоритет pr1, pr2 для обоих потоков соответственно
   SetThreadPriority(sort_thread, pr1);
   SetThreadPriority(print_thread, pr2);
 
   // активизируем потоки
   ResumeThread(print_thread);
   ResumeThread(sort_thread);
 
   // ждём окончания работы потоков
   while (WaitForSingleObject(sort_thread, INFINITE) != WAIT_OBJECT_0 || 
          WaitForSingleObject(print_thread, INFINITE) != WAIT_OBJECT_0);
        GetSystemTime(&end_time);
   PrintCurrentTime("\nKonec raboty: ");
 
   // выводим разницу во времени
   PrintTimeDiff(start_time, end_time);
   cout << endl;
}
//---------------------------------------------------------------------------
DWORD WINAPI print(void *parg)
{
   cout << "Soderjimoe massiva: \n";
   int i;
   for (i = 0; i < ARR_LEN; i++)
   {
        cout << arr[i] << ' ';
   }
   return 0;
}
//---------------------------------------------------------------------------
DWORD WINAPI sort(void *parg)
{
   insert_sorting(arr, ARR_LEN);
   return 0;
}
//---------------------------------------------------------------------------
void insert_sorting(int *a, int count)
{
    int i, j, tmp;
    for (i = 1; i < count; ++i)                     
    {
        tmp = a[i]; 
        for (j = i - 1; j >= 0 && a[j] < tmp; --j)  
        {
            a[j + 1] = a[j];                        
        }
        a[j + 1] = tmp;                             
    }
 
}
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
23.09.2012, 11:07
Я подобрал для вас темы с готовыми решениями и ответами на вопрос Работа с потоками идет не так, как надо. Почему? (C++):

Цикл не работает так как надо - C++
Всем привет! Народ, у меня цикл в программе работает не так как надо. 1 круг цикла происходит в норме, а когда начинается 2ой он...

Работает не так как надо(классы) - C++
Задача. Создать класс хранящий в себе инн. Проверить его на верность и вывести результат. class NIP { public: NIP(const...

Вывод из файла работает на так как надо - C++
Привет всем) У меня проблемка.. Я делаю тест на с++ и проблема в том что последнюю строчку из файла показывает 4 раза.. подскажите как это...

не могу понять,почему не идет - C++
#include &quot;stdafx.h&quot; #include &lt;iostream&gt; #include &lt;stdio.h&gt; #include &lt;math.h&gt; struct crs Matrix { int N; int Nz;...

не пойму почему не идет программа - C++
Дана последовательность из n целых чисел. Определить, все ли числа являются нулевыми или первое ненулевое число является положительным. ...

Почему неправильно идет запись в файл? - C++
Подскажите,я работаю со структурами,предположим ввожу номер банковского счета,фамилия,день,сумма вклада,процент начисления.Например: 1...

26
Gooman
10 / 10 / 0
Регистрация: 03.10.2010
Сообщений: 350
23.09.2012, 11:50  [ТС] #16
Цитата Сообщение от John Prick Посмотреть сообщение
Откуда ты знаешь? Выведи массив до того, как запустишь хоть какие-то потоки.
Я только что это сделал. Не надо дураком меня считать. При каждом вызове функции создания двух потоков он заново заполняет массив, который не отсортирован.
0
Nixy
ComfyMobile
400 / 281 / 8
Регистрация: 24.07.2012
Сообщений: 916
23.09.2012, 11:50 #17
ну подебажив немного , я увидел что поток вывоа успел написать две буквы "So" а потом началась сортировка 286 элементов и мне кажется не придел поэтому пока ты выведешь слово "Soderjimoe massiva"
как минимум массив 3000 элементов уже отсортируется но повторю это не предел

2864559 делает мгновенно сортировку попробуй вручную останавливать сортировку
0
Gooman
10 / 10 / 0
Регистрация: 03.10.2010
Сообщений: 350
23.09.2012, 11:53  [ТС] #18
Цитата Сообщение от Nixy Посмотреть сообщение
ну подебажив немного , я увидел что поток вывоа успел написать две буквы "So" а потом началась сортировка 286 элементов и мне кажется не придел поэтому пока ты выведешь слово "Soderjimoe massiva"
как минимум массив 3000 элементов уже отсортируется но повторю это не предел
И как мне тогда сделать, чтобы при приоритете HIGHEST у вывода и IDLE у сортировки массив сначала вывелся, а потом отсортировался? Убрал вывод фразу "содержимое" массива, теперь первый элемент массива не отсортирован. Хм, перезапустил, уже сортируется благополучно, как раньше.
0
John Prick
831 / 764 / 154
Регистрация: 27.07.2012
Сообщений: 2,176
Завершенные тесты: 3
23.09.2012, 11:55 #19
Nixy, ты прав. Если закомментировать строку с выводом в консоль, уже появляются в начале вывода неотсортированные элементы.
0
Gooman
10 / 10 / 0
Регистрация: 03.10.2010
Сообщений: 350
23.09.2012, 11:56  [ТС] #20
Цитата Сообщение от John Prick Посмотреть сообщение
Nixy, ты прав. Если закомментировать строку с выводом в консоль, уже появляются в начале вывода неотсортированные элементы.
А после перекомпилирования (ничего не меняя, строки "содержимое массива " нет) они исчезают. Что это такое? Очень интересно. Если убрать эту строку, скомпилировать, то в начале будет неотсортированный элемент. Перекомпилируем еще раз, его уже нет. Добавим в программу комментарий, скомпилируем, он есть. Скомпилируем еще раз, его нет. Что это?
0
John Prick
831 / 764 / 154
Регистрация: 27.07.2012
Сообщений: 2,176
Завершенные тесты: 3
23.09.2012, 11:58 #21
Цитата Сообщение от Gooman Посмотреть сообщение
И как мне тогда сделать, чтобы при приоритете HIGHEST у вывода и IDLE у сортировки массив сначала вывелся, а потом отсортировался?
Вывод в консоль - долгая песня, поэтому пока твой поток вывода пытается вывести первые элементы, поток сортировки уже успевает отсортировать значительную часть массива.
1
Nixy
ComfyMobile
400 / 281 / 8
Регистрация: 24.07.2012
Сообщений: 916
23.09.2012, 12:01 #22
Цитата Сообщение от John Prick Посмотреть сообщение
значительную часть массива.
я бы сказал ВСЮ
28645559 при таком размере уже рушится сортировка
1
John Prick
831 / 764 / 154
Регистрация: 27.07.2012
Сообщений: 2,176
Завершенные тесты: 3
23.09.2012, 12:01 #23
Цитата Сообщение от Gooman Посмотреть сообщение
А после перекомпилирования (ничего не меняя, строки "содержимое массива " нет) они исчезают. Что это такое?
РАспределение времени на потоки в системе не детерминировано. Ну т.е. не повторяется от запуска к запуску. Сегодня так, завтра по-другому. Я пробую твой пример. У меня стабильно 1-2 неотсортированных элемента выводится сначала, потом уже всё отсортировано.
1
Gooman
10 / 10 / 0
Регистрация: 03.10.2010
Сообщений: 350
23.09.2012, 12:04  [ТС] #24
Куда можно вывести, чтобы вывод был быстрым? Кажется, я знаю, куда. Надо воспользоваться cmd. Скопировать туда адрес к Thread.exe, через пробел написать Thread.exe > "D:\test.txt" . И файле получил тот результат, который мне нужен (idle-highest наконец-то не сортируется )
0
John Prick
831 / 764 / 154
Регистрация: 27.07.2012
Сообщений: 2,176
Завершенные тесты: 3
23.09.2012, 12:07 #25
Цитата Сообщение от Gooman Посмотреть сообщение
Куда можно вывести, чтобы вывод был быстрым?
Копируй в другой массив. А после завершения работы потоков, выводи копию.

Добавлено через 26 секунд
Ну т.е. не выводи в теле потока.
1
Nixy
ComfyMobile
400 / 281 / 8
Регистрация: 24.07.2012
Сообщений: 916
23.09.2012, 12:07 #26
John Prick, хорошая идея
1
Gooman
10 / 10 / 0
Регистрация: 03.10.2010
Сообщений: 350
23.09.2012, 12:08  [ТС] #27
Цитата Сообщение от John Prick Посмотреть сообщение
Копируй в другой массив. А после завершения работы потоков, выводи копию.

Добавлено через 26 секунд
Ну т.е. не выводи в теле потока.
Щас еще так попробую. Да, выводится не по порядку. Вот только не всегда: один раз запустишь и все нормально, а другой раз запустишь и нормально отсортировано только в idle-normal.
0
23.09.2012, 12:08
MoreAnswers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
23.09.2012, 12:08
Привет! Вот еще темы с ответами:

Почему так происходит и как это устранить - C++
почему если я напишу вот так - #include &lt;stdio.h&gt; #include &lt;iostream&gt; using namespace std; int main() { ...

Почему цикл работает не так, как ожидается? - C++
Двумя способами реализовал цикл, который увеличивает годовую зарплату на 10% при нажатии 'y' до тех пор пока не будет введен символ 'n', но...

Работа с потоками - C++
Пишу простой RSS агрегатор и уже практически доделал его в программе параллельно устанавливается соединение и потом извлекаем данные из...

Работа с потоками - C++
Задача поставлена так : Необходимо открыть поток, записать некую информацию и далее закрыть его. Но необходимо, чтобы после закрытия...


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

Или воспользуйтесь поиском по форуму:
27
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2018, vBulletin Solutions, Inc.
Рейтинг@Mail.ru