Форум программистов, компьютерный форум CyberForum.ru

Синхронизация потоков в С++ - C++

Войти
Регистрация
Восстановить пароль
Другие темы раздела
C++ перевод из системы в систему http://www.cyberforum.ru/cpp-beginners/thread122745.html
помогите пожалуйста перевести на С++ uses crt; const s:string='0123456789ABCDEF'; c:array of byte=(0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15); function Pow16(n:byte):longint; var p:longint; i:byte; begin p:=1;
C++ Постигая рекурсию. Прошу поправить мою прогу. По заданию должна быть с рекурсией, я понимаю как она работает, но как правильно её написать я не уверен. #include <stdio.h> #include <stdlib.h> #include <math.h> void inp(int *N, double *X) { printf("Sissestage X: "); scanf("%d", &X); http://www.cyberforum.ru/cpp-beginners/thread122727.html
В массиве найти количество нечетных чисел расположенных после второго самого большего числа C++
Срочно плиз помогите для курсача написать программку на C В массиве найти количество нечетных чисел расположенных после второго самого большего числа
Дан файл f и g, компоненты которых являются целыми числами в машинном представлении. Записать в файл h числа из файлов f и g повторяющиеся в обоих фай C++
Дан файл f и g, компоненты которых являются целыми числами в машинном представлении. Записать в файл h числа из файлов f и g повторяющиеся в обоих файлах ровно 2 раза.
C++ в текстовом редакторе создать файл, содержащий текст, длина которого не превышает 1000 символов (длина строки текста не должна превышать http://www.cyberforum.ru/cpp-beginners/thread122701.html
С помощью текстового редактора создать файл, содержащий текст, длина которого не превышает 1000 символов (длина строки текста не должна превышать 70 символов). Имя файла должно иметь расширение DAT. Написать программу, которая: выводит текст на экран дисплея; определяет самую длинную последовательность цифр в тексте (любое количество пробелов и концы строк не прерывают последовательность...
C++ Нужно перевести код из Pascal в С Помогите пожалуйста перевести паскалевский код на Си(без плюсов, хотя и с плюсами тоже можно). Заранее спасибо. Вот код: unit Interpol; interface uses Types; подробнее

Показать сообщение отдельно
erazer89
1 / 1 / 0
Регистрация: 18.12.2008
Сообщений: 6

Синхронизация потоков в С++ - C++

27.04.2010, 20:16. Просмотров 700. Ответов 0
Метки (Все метки)

Синхронизация потоков в пользовательском режиме с помощью Interlocked-функций
Задача: После запуска программы основной процесс спрашивает путь к файлу с вектором для суммирования. Файл содержит элементы вектора (положительные целые числа), разделенные символом ','. Считав данные из файла, программа выводит количество элементов и спрашивает о количестве необходимых потоков для вычисления суммы. Распределив поровну элементы вектора между введенным количеством потоков, основной процесс создает потоки, передавая в них части вектора. Поток, на основе входных данных, суммирует элементы вектора, занося результат в общую переменную. По завершению работы потока, на экран выводится сообщение с информацией о номере потока и его вычисленной сумме. После того, как все потоки закончат работу, основной процесс выводит общий результат суммирования.
Программа работает нормально, но с течением времени сказали изменить этот текстовый файл в котором хранится вектор, содержимое файла было в одну строку и все работало хорошо, но теперь у нас там две строки с данными, а наша программа работает только с одной. Нам подсказали, что нужно сделать вместо одного fgets два и как то их там объеденить. Подскажите как это сделать?
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
#include <iostream>
#include <conio.h>
#include <stdlib.h>
#include <windows.h>
 
using namespace std;
 
LONG Sum = 0; // Глобальная переменная для суммы элементов вектора
 
// Объявление структуры Вектор (с псевдонимом ВЕКТОР)
typedef struct Vector
{
int *data; // элементы вектора
int count; // количество элементов
} VECTOR;
 
// Функция потока
DWORD WINAPI ThreadFunc(LPVOID vect)
{
VECTOR* vec;
vec = (VECTOR*)vect;
int vecsum = 0;
for(int i = 0; i < vec->count; i++)
vecsum += vec->data[i];
InterlockedExchangeAdd(&Sum, vecsum);
}
 
int main(void)
{
VECTOR vecf, *vect; // структура для общего вектора, считанного с файла, и для массива векторов для потоков
DWORD *dwThreadIds, dwThreadsCount, dwElemInThread; //массив идентификаторов потока, кол-во потоков, кол-во элементов в потоке соответсвенно
HANDLE *hThread; //массив дескрипторов потока
FILE *hFile; // дескриптор открываемого файла
char *tmp; // строка для имени файла и для его содержимого
BOOL parity; // четность деления кол-ва потоков и кол-ва элементов
 
vecf.count = 0;
cout << "Enter full path to file" << endl << "> ";
cin >> tmp;
delete [] tmp;
 
hFile = fopen(tmp, "rt");
if (hFile == NULL)
{
cout << "Error: Invalid filename." << endl;
return 1;
}
fseek(hFile, 0, SEEK_END); // file
int fsize = ftell(hFile) + 1; // bytes
fseek(hFile, 0, SEEK_SET); // count
tmp = new char[fsize];
fgets(tmp, fsize, hFile);
for (int i = 0; tmp[i] != '\0'; i++) // подсчет запятых в строке (для подсчета элементов вектора)
if(tmp[i] == ',') vecf.count++;
vecf.data = new int[vecf.count+1]; // memory alloc for vector data ( ',' count = 5, elements count = 5+1)
cout << "Given vector: ";
vecf.count = 0;
// Разбиение строки на элементы (с использованием разделителя ",")
vecf.data[0] = atoi(strtok(tmp, ",")); // atoi - перевод строки в число
while (vecf.data[vecf.count] != '\0')
{
cout << vecf.data[vecf.count] << " ";
vecf.count++;
vecf.data[vecf.count] = atoi(strtok(NULL, ","));
}
delete [] tmp;
 
cout << endl << "Elements count: " << vecf.count << endl;
cout << "Enter threads count: " << endl << "> ";
cin >> dwThreadsCount;
if (dwThreadsCount > vecf.count)
{
cout << "Error: Enter number of threads less than number of elements." << endl;
return 2;
}
 
vect = new VECTOR[dwThreadsCount];
dwThreadIds = new DWORD[dwThreadsCount];
hThread = new HANDLE[dwThreadsCount];
if (vecf.count % dwThreadsCount == 0) // определяем, четно ли делится кол-во элементов на кол-во потоков
parity = TRUE;
else
parity = FALSE;
dwElemInThread = vecf.count / dwThreadsCount;
int offset = 0;
for (unsigned int a = 0; a < dwThreadsCount; a++)
{
if (a == 0 && parity == FALSE) vect[a].count = dwElemInThread + (vecf.count % dwThreadsCount);
else vect[a].count = dwElemInThread;
vect[a].data = new int[vect[a].count];
for (int j = 0; j < vect[a].count; j++)
vect[a].data[j] = vecf.data[j+offset];
offset += vect[a].count;
hThread[a] = CreateThread(NULL, 0, ThreadFunc, &vect[a], 0, &dwThreadIds[a]); //создание потока
}
 
WaitForMultipleObjects(dwThreadsCou nt, hThread, TRUE, INFINITE); // wait for thread ending
cout << "Sum of elements = " << Sum << endl;
for (unsigned int a = 0; a < dwThreadsCount; a++)
delete [] vect[a].data;
delete [] vecf.data;
delete [] vect;
delete [] dwThreadIds;
delete [] hThread;
fclose(hFile);
_getch();
return 0;
}
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
 
Текущее время: 17:48. Часовой пояс GMT +3.
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2017, vBulletin Solutions, Inc.
Рейтинг@Mail.ru