Потоки

luciys · Регистрация: 27.11.2012

Студворк — интернет-сервис помощи студентам

Есть файлы. Необходимо создать n потоков, которые будут обрабатывать их .

часть с потоками :

C
1
2
3
4
5
6
7
8
9
10
for (i = 0; i < kol_threads; i++) {
        ind[i] = i;
        if (pthread_create(&threads[i], NULL, &scan, &ind[i]) == 0)
            perror("ERROR");
    }
        
    
    for (i = 0; i < kol_threads; i++)
        if (pthread_join(threads[i], NULL) == 0)
            perror("ERROR");

функция обработки :

C
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
void *scan(void *arg) {
    FILE *f;
    unsigned long int kol;
    unsigned int c, i;
    for (i = * (unsigned int *) arg; i < kol_files; i += kol_threads) 
    {
        kol = 0;
        
        if ((f = fopen(files[i],"r")) == NULL) {
            perror("ERROR");
            continue;
        }
        while ((c = fgetc(f)) != EOF) 
            kol++;
        if (fclose(f) == EOF) 
            perror("ERROR");    
 
        printf("%u %s %i\n", pthread_self(), files[i], kol);
 
    }
}

Кажется, что я всё таки делаю неправильно . Часть файлов, примерно первая половина, потоки обрабатывают, вроде, нормально, т.е. они по очереди обрабатываются, а другая часть блоками . (в первой половине примерно такой вывод: 1 поток... , 2 поток..., 4 поток..., n поток..., а во второй: 10 поток..., 10 поток..., 10 поток... так, например, файлов 15, потом так же другой поток обрабатывает какое то количество файлов, ну и тд блоки потоков чередуются ) . Надеюсь донёс суть проблемы )

Или возможно как-то контролировать количество потоков ? Создаю n потоков, жду пока какой нибудь завершится, затем создаю новый .

@gng · 17.05.2014, 21:47

Сообщение от luciys

Кажется, что я всё таки делаю неправильно

Сложно ответить однозначно. За время, которое планировщик дает потоку доступ к файловым операциям, можно прочитать и несколько файлов, а можно и часть одного файла. Зависит от размеров файлов, алгоритма работы планировщика, размеров дискового кэша и т.д.

luciys · 18.05.2014, 12:14 **[ТС]**

gng, но первая половина работает же правильно, в моём понимании . Причём так происходит постоянно, результат неизменен: 1 часть норм, 2 гг . Что может измениться за это время, что вторая "абы как" работает ?

@gng · 18.05.2014, 13:33

luciys, я вам высказал своё видение ситуации. Ошибки в приведенном коде я не заметил. Не вижу оснований и для ожидания, что вывод результатов в stdout будет проходить последовательно по 1 строке на поток. Тем более, что на скорость выполнения это вряд ли заметно влияет. Все узкие места - и вывод результатов на stdout, и чтение из файлов (во всяком случае при непопадании в кэш) выполняются последовательно.
Почему ситуация меняется со временем? Не знаю. Может, планировщик со временем понимает, что так быстрее, чем бессмысленно тратить время на переключение потоков.

Новые блоги и статьи Все статьи Все блоги /
Перемещение выделенных строк ТЧ из одного документа в другой Maks 30.03.2026 Реализация из решения ниже выполнена на примере нетипового документа "ВыдачаОборудованияНаСпецтехнику" с единственной табличной частью "ОборудованиеИКомплектующие" разработанного в конфигурации КА2. . . .	Functional First Web Framework Suave DevAlt 30.03.2026 Sauve. IO Апнулись до NET10. Из зависимостей один пакет, работает одинаково хорошо как в режиме проекта так и в интерактивном режиме. из сложностей - чисто функциональный подход. Решил. . .	Автоматическое создание документа при проведении другого документа Maks 29.03.2026 Реализация из решения ниже выполнена на нетиповых документах, разработанных в конфигурации КА2. Есть нетиповой документ "ЗаявкаНаРемонтСпецтехники" и нетиповой документ "ПланированиеСпецтехники". В. . .	Настройка движения справочника по регистру сведений Maks 29.03.2026 Решение ниже реализовано на примере нетипового справочника "ТарифыМобильнойСвязи" разработанного в конфигурации КА2, с целью учета корпоративной мобильной связи в коммерческом предприятии. . . .
Автозаполнение реквизита при выборе элемента справочника Maks 27.03.2026 Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. При выборе "Спецтехники" (Тип Справочник. Спецтехника), заполняется. . .	Сумматор с применением элементов трёх состояний. Hrethgir 26.03.2026 Тут. https:/ / fips. ru/ EGD/ ab3c85c8-836d-4866-871b-c2f0c5d77fbc Первый документ красиво выглядит, но без схемы. Это конечно не даёт никаких плюсов автору, но тем не менее. . . всё может быть. . .	Автозаполнение реквизитов при создании документа Maks 26.03.2026 Программный код из решения ниже размещается в модуле объекта документа, в процедуре "ПриСозданииНаСервере". Алгоритм проверки заполнения реализован для исключения перезаписи значения реквизита,. . .	Команды формы и диалоговое окно Maks 26.03.2026 1. Команда формы "ЗаполнитьЗапчасти". Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. В качестве источника данных. . .

luciys 6 / 6 / 1 Регистрация: 27.11.2012 Сообщений: 160
	18.05.2014, 12:14 [ТС]
	gng, но первая половина работает же правильно, в моём понимании . Причём так происходит постоянно, результат неизменен: 1 часть норм, 2 гг . Что может измениться за это время, что вторая "абы как" работает ? 0

@gng 923 / 639 / 198 Регистрация: 08.09.2013 Сообщений: 1,693
	18.05.2014, 13:33
	luciys, я вам высказал своё видение ситуации. Ошибки в приведенном коде я не заметил. Не вижу оснований и для ожидания, что вывод результатов в stdout будет проходить последовательно по 1 строке на поток. Тем более, что на скорость выполнения это вряд ли заметно влияет. Все узкие места - и вывод результатов на stdout, и чтение из файлов (во всяком случае при непопадании в кэш) выполняются последовательно. Почему ситуация меняется со временем? Не знаю. Может, планировщик со временем понимает, что так быстрее, чем бессмысленно тратить время на переключение потоков. 0