Создание потоков для работы со строками

@leva · Регистрация: 12.04.2012

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

Мне нужно много поточное приложение которое может отрыть текстовый файл и в разных потоках работать с этими строками но в каждом потоке должна быть своя строка то есть в первом потоке первая строка из листа в это время второй поток берет 2 строку а третий третью строку и.т.д .
Вот как я это реализовал

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
//---------------------------------------------------------------------------
#include <vcl.h>
#pragma hdrstop
#include "Unit1.h"
//---------------------------------------------------------------------------
#pragma package(smart_init)
#pragma resource "*.dfm"
#include "process.h"
TForm1 *Form1;
TStringList *Навход = new TStringList; // Стринг лист для загрузки файла
//---------------------------------------------------------------------------
__fastcall TForm1::TForm1(TComponent* Owner)
    : TForm(Owner)
{
}
//---------------------------------------------------------------------------
void __fastcall TForm1::Button1Click(TObject *Sender)
{
if(Form1->OpenTextFileDialog1->Execute()){  //загрузка строк текстового файла
       Навход->LoadFromFile(Form1->OpenTextFileDialog1->FileName);
}
}
void Thread1(void *Param) { //Поток для работы
for(int i = 0; i < Навход->Count/3; i++){//Цикл бежит по строкам из Листа "Навход" от 0 до количества строк в Листе делить на 2 поскольку  у нас 4 потока)
Form1->Memo1->Lines->Add(Навход->Strings[i]); //Вывод в мемо поле строки из листа
}
 _endthread();
}
void Thread2(void *Param) { //Поток для работы
for(int i = Навход->Count/3; i < Навход->Count/2; i++){//Цикл бежит по строкам из Листа "Навход" количества строк в Листе делить на 2 поскольку у нас 4 потока до количество строк делить на 3 )
Form1->Memo1->Lines->Add(Навход->Strings[i]); //Вывод в мемо поле строки из листа
}
 _endthread();
}
void Thread3(void *Param) { //Поток для работы
for(int i = Навход->Count/2; i < Навход->Count; i++){//Цикл бежит по строкам из Листа "Навход" количества строк в Листе делить на 3 поскольку у нас 4 потока до количество строк в Листе)
Form1->Memo1->Lines->Add(Навход->Strings[i]); //Вывод в мемо поле строки из листа
}
_endthread();
}
/*
Таким образом мы смогли создать 3 потока которые идут по одному стринг листу
Но по разным строкам.
   */
//---------------------------------------------------------------------------
void __fastcall TForm1::Button2Click(TObject *Sender)
{
_beginthread(Thread1, 0, (void*)(0));
_beginthread(Thread2, 0, (void*)(0));
_beginthread(Thread3, 0, (void*)(0));
}
//---------------------------------------------------------------------------

Но хотелось бы не три потока и описывать их каждый раз а столько потоков сколько допустим укажу в едит поле. И так какие вопросы как создать 50 или 100 потоков делающих одну функцию но с разными строками и не описывать каждый поток а то так код может из за 1000 строк перевалить если 100 потоков в ручную описывать что приведет к огромному размеру программы. Не понятно как в цикле создать потоки и передать им № потока ну для работы со строками ну или как то еще.
Прошу помогите если не понятно что я тут написал смотрите на код сверху.
Спасибо всем кто поможет.)

@Maluda · 05.06.2012, 17:51

Самая главная ошибка: ты добавляешь строки в Мемо из других потоков без синхронизации.

2 ошибка: добавляешь текст построчно, вместо того, чтобы добавить целиком и запретить перерисовку

C++
1
2
3
    Memo1->Lines->BeginUpdate();
           Memo1->Lines->AddStrings(Навход);
    Memo1->Lines->EndUpdate();

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

TStringList *Навход = new TStringList; // Стринг лист для загрузки файла

3 ошибка: здесь ты создаёшь объект, а где удаление этого объекта?

@leva · 05.06.2012, 18:42 **[ТС]**

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

Самая главная ошибка: ты добавляешь строки в Мемо из других потоков без синхронизации.

2 ошибка: добавляешь текст построчно, вместо того, чтобы добавить целиком и запретить перерисовку

C++
1
2
3
    Memo1->Lines->BeginUpdate();
           Memo1->Lines->AddStrings(Навход);
    Memo1->Lines->EndUpdate();

3 ошибка: здесь ты создаёшь объект, а где удаление этого объекта?

Да про ошибки знаю мне тут главное узнать как потоки в цикле создать и не описывать каждый поток отдельно, а про мемо почему не льзя добавлять по строчно?

@Maluda · 06.06.2012, 00:43

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

про мемо почему не льзя добавлять по строчно?

Можно и построчно, но у тебя объект TStringList тремя разными потоками построчно добавляется в другой TStringList, который является членом класса TMemo и каждый раз при добавлении строки тратится время на перерисовку TMemo, поэтому, чтобы выиграть во времени (а я так понимаю, для тебя это главное), лучше заблокировать отрисовку контрола, затем единой транзакцией добавить все строки и потом разблокировать отрисовку. Я тебе гарантирую увеличение по скорости раз в десять.

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

как потоки в цикле создать

Во-первых, если пользоваться потоками для того, чтобы из них обновлять VCL контролы, то, необходимо использовать VCL потоки TThread с вызовом метода Synchronize.

Во-вторых, если хочешь свои потоки в цикле создать, то в чём проблема?

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
std::auto_ptr<TStringList>AMyList(new TStringList);
 
void ThreadFunc(void *Param) { 
        // получаем переменную переданную в текущий поток, 
        // в данном случае для примера - это ID нашего потока
    const int iParam = (int)Param;
 
        // выполняем какие-то действия в зависимости от ID потока
    AMyList->Add(iParam);
 
    _endthread();
}
 
 
//---------------------------------------------------------------------------
void __fastcall TForm2::btnMyClick(TObject *Sender) {
    // создадим 10 потоков и передадим им функцию с параметром равным индексу потока
        for (int i = 0; i < 10; i++) {
         _beginthread(ThreadFunc, 0, (void *)i);
    }
}

@leva · 06.06.2012, 22:41 **[ТС]**

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

Можно и построчно, но у тебя объект TStringList тремя разными потоками построчно добавляется в другой TStringList, который является членом класса TMemo и каждый раз при добавлении строки тратится время на перерисовку TMemo, поэтому, чтобы выиграть во времени (а я так понимаю, для тебя это главное), лучше заблокировать отрисовку контрола, затем единой транзакцией добавить все строки и потом разблокировать отрисовку. Я тебе гарантирую увеличение по скорости раз в десять.

Во-первых, если пользоваться потоками для того, чтобы из них обновлять VCL контролы, то, необходимо использовать VCL потоки TThread с вызовом метода Synchronize.

Во-вторых, если хочешь свои потоки в цикле создать, то в чём проблема?

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
std::auto_ptr<TStringList>AMyList(new TStringList);
 
void ThreadFunc(void *Param) { 
        // получаем переменную переданную в текущий поток, 
        // в данном случае для примера - это ID нашего потока
    const int iParam = (int)Param;
 
        // выполняем какие-то действия в зависимости от ID потока
    AMyList->Add(iParam);
 
    _endthread();
}
 
 
//---------------------------------------------------------------------------
void __fastcall TForm2::btnMyClick(TObject *Sender) {
    // создадим 10 потоков и передадим им функцию с параметром равным индексу потока
        for (int i = 0; i < 10; i++) {
         _beginthread(ThreadFunc, 0, (void *)i);
    }
}

Спасибо огромное, а если в стринг лист много потоков будут записывать строки, то все нормально будет? без вывода в мемо!

@Maluda · 07.06.2012, 08:33

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

если в стринг лист много потоков будут записывать строки, то все нормально будет?

Если список несортированный и строки добавляются в конец списка, то, думаю, да.

@MikeSoft · 07.06.2012, 10:54

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

2 ошибка: добавляешь текст построчно, вместо того, чтобы добавить целиком и запретить перерисовку

C++
1
2
3
Memo1->Lines->BeginUpdate();
Memo1->Lines->AddStrings(Навход);
Memo1->Lines->EndUpdate();

Попробуйте проверить то, что советуете...
Метод AddStrings внутри себя вызывает вышеуказанные методы блокировок.
Если хотите выполнить загрузку большого количества строк быстрее - воспользуйтесь классом TMemoryStream.

Ну и для интереса, выполните такой тест:

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
const int ItemsCount = 100000;
unsigned long Start, Stop;
int i;
TStringList *SList = new TStringList();
for (i = 0; i < ItemsCount; SList->Add("Line " + IntToStr(i)), i++);
 
//------ With BeginUpdate & EndUpdate methods ------
Memo1->Lines->BeginUpdate();
Start = GetTickCount();
for (i = 0; i < ItemsCount; Memo1->Lines->Add("Line " + IntToStr(i)), i++);
Stop = GetTickCount();
Memo1->Lines->EndUpdate();
Memo1->Clear();
ShowMessage(Stop - Start);
//--------------------------------------------------
 
//---------------- Only Add method -----------------
Start = GetTickCount();
for (i = 0; i < ItemsCount; Memo1->Lines->Add("Line " + IntToStr(i)), i++);
Stop = GetTickCount();
Memo1->Clear();
ShowMessage(Stop - Start);
//--------------------------------------------------
 
//------------ Only AddStrings method --------------
Start = GetTickCount();
Memo1->Lines->AddStrings(SList);
Stop = GetTickCount();
Memo1->Clear();
ShowMessage(Stop - Start);
//--------------------------------------------------
 
//---------- Loading from TMemoryStream ------------
TMemoryStream *MStream = new TMemoryStream();
MStream->Position = soFromBeginning;
SList->SaveToStream(MStream);
MStream->Position = soFromBeginning;
Start = GetTickCount();
Memo1->Lines->LoadFromStream(MStream);
Stop = GetTickCount();
Memo1->Clear();
ShowMessage(Stop - Start);
//--------------------------------------------------
 
delete MStream;
delete SList;

Результаты в Release-варианте должны быть примерно следующие:

14 212 мс. - добавление через Add, с методами BeginUpdate & EndUpdate.
12 730 мс. - добавление только через Add.
13 260 мс. - метод AddStrings.
2 668 мс. - TMemoryStream и LoadFromStream.

@leva · 07.06.2012, 11:39 **[ТС]**

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

Попробуйте проверить то, что советуете...
Метод AddStrings внутри себя вызывает вышеуказанные методы блокировок.
Если хотите выполнить загрузку большого количества строк быстрее - воспользуйтесь классом TMemoryStream.

Ну и для интереса, выполните такой тест:

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
const int ItemsCount = 100000;
unsigned long Start, Stop;
int i;
TStringList *SList = new TStringList();
for (i = 0; i < ItemsCount; SList->Add("Line " + IntToStr(i)), i++);
 
//------ With BeginUpdate & EndUpdate methods ------
Memo1->Lines->BeginUpdate();
Start = GetTickCount();
for (i = 0; i < ItemsCount; Memo1->Lines->Add("Line " + IntToStr(i)), i++);
Stop = GetTickCount();
Memo1->Lines->EndUpdate();
Memo1->Clear();
ShowMessage(Stop - Start);
//--------------------------------------------------
 
//---------------- Only Add method -----------------
Start = GetTickCount();
for (i = 0; i < ItemsCount; Memo1->Lines->Add("Line " + IntToStr(i)), i++);
Stop = GetTickCount();
Memo1->Clear();
ShowMessage(Stop - Start);
//--------------------------------------------------
 
//------------ Only AddStrings method --------------
Start = GetTickCount();
Memo1->Lines->AddStrings(SList);
Stop = GetTickCount();
Memo1->Clear();
ShowMessage(Stop - Start);
//--------------------------------------------------
 
//---------- Loading from TMemoryStream ------------
TMemoryStream *MStream = new TMemoryStream();
MStream->Position = soFromBeginning;
SList->SaveToStream(MStream);
MStream->Position = soFromBeginning;
Start = GetTickCount();
Memo1->Lines->LoadFromStream(MStream);
Stop = GetTickCount();
Memo1->Clear();
ShowMessage(Stop - Start);
//--------------------------------------------------
 
delete MStream;
delete SList;

Результаты в Release-варианте должны быть примерно следующие:

Отлично спасибо но я полностью отказался от вывода буду в текстовый файл строки записывать.

@Maluda · 07.06.2012, 16:49

MikeSoft, я всегда проверяю, то что советую! Я абсолютно согласен с тем,
что через потоки быстрее, но в корне не согласен, что Add без BeginUpdate и EndUpdate быстрее??? AddStrings, как показано в ваших результатах. По моим результатам AddStrings быстрее в 7 раз! Прилагаю код, который проверял и параметры своей машины, на которой тестил:
Intel Core 2 Quad Q6600 2.4 GHz
CBuilder 2010
Windows XP Service Pack 3

П.С. К тому же, если внимательно посмотрите на код, который приложу ниже, то увидите,
что есть ещё один, наверное, лучший способ.
П.С.2 Отсчёт времени при измерении копирования потоком необходимо начать до объявления потока

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
//---------------------------------------------------------------------------
void __fastcall TForm1::Button1Click(TObject *Sender) {
    const int ItemsCount = 100000;
    unsigned long Start, Stop;
    int i;
    TStringList *SList = new TStringList();
    for (i = 0; i < ItemsCount; SList->Add("Line " + IntToStr(i)), i++);
 
    // ВОТ ТАК ДЕЛАЛОСЬ ДОБАВЛЕНИЕ У ПОЛЬЗОВАТЕЛЯ [B]leva[/B]
    //---------------- Only Add method -----------------
    Start = GetTickCount();
    for (i = 0; i < ItemsCount; Memo1->Lines->Add("Line " + IntToStr(i)), i++);
    Stop = GetTickCount();
 
    ShowMessage("Время добавления через Add - " + UnicodeString(Stop - Start));
 
    Memo1->Clear();
    //--------------------------------------------------
 
    // ВОТ ТАК ПОСОВЕТОВАЛ Я
    //------------ AddStrings method --------------
    Start = GetTickCount();
    Memo1->Lines->BeginUpdate();
    Memo1->Lines->AddStrings(SList);
    Memo1->Lines->EndUpdate();
    Stop = GetTickCount();
 
    ShowMessage("Время добавления через AddStrings - " + UnicodeString(Stop - Start));
 
    Memo1->Clear();
    //--------------------------------------------------
 
    //---------- Loading from TMemoryStream ------------
    Start = GetTickCount(); // ОТСЧЁТ НЕОБХОДИМО НАЧАТЬ ОТСЮДА
 
    TMemoryStream *MStream = new TMemoryStream();
    MStream->Position = soFromBeginning;
    SList->SaveToStream(MStream);
    MStream->Position = soFromBeginning;
    Memo1->Lines->LoadFromStream(MStream);
    delete MStream;
 
    Stop = GetTickCount();
 
    ShowMessage("Время добавления через TMemoryStream - " + UnicodeString(Stop - Start));
    Memo1->Clear();
 
    //---------- Ради интереса ------------
    Start = GetTickCount();
 
    Memo1->Lines->Text = SList->Text;
 
    Stop = GetTickCount();
    ShowMessage("Время добавления простым присваиванием - " + UnicodeString(Stop - Start));
    // --------------------------------------------------
 
    delete SList;
}
//---------------------------------------------------------------------------

Результы:
Add - 30.453 сек
AddStrings - 4.594 сек
TMemoryStream - 0.922 сек
Простое копирование - 0.906 сек

@Maluda · 07.06.2012, 16:57

MikeSoft, и самое главное ! Речь шла о добавлении строк а не о копировании всего текста! Вы каждый раз очищаете Memo!
А у пользователя Memo будет постепенно заполняться строками из открытого файла. Я не видел у него в коде при открытии файла очистку Memo.

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

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
//---------------------------------------------------------------------------
void __fastcall TForm1::Button1Click(TObject *Sender)
{
if(Form1->OpenTextFileDialog1->Execute()){ //загрузка строк текстового файла
 Навход->LoadFromFile(Form1->OpenTextFileDialog1->FileName);
}
}
void Thread1(void *Param) { //Поток для работы
for(int i = 0; i < Навход->Count/3; i++){//Цикл бежит по строкам из Листа "Навход" от 0 до количества строк в Листе делить на 2 поскольку у нас 4 потока)
Form1->Memo1->Lines->Add(Навход->Strings[i]); //Вывод в мемо поле строки из листа
}
 _endthread();
}

@leva · 07.06.2012, 22:24 **[ТС]**

Помогите что с кодом вроде такой же как я выше писал, но все потоки тут же завершаются без ошибок

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
//---------------------------------------------------------------------------
 
#include <vcl.h>
#pragma hdrstop
 
#include "Unit1.h"
//---------------------------------------------------------------------------
#pragma package(smart_init)
#pragma link "sButton"
#pragma link "sMemo"
#pragma link "sEdit"
#pragma link "sDialogs"
#pragma resource "*.dfm"
#include "process.h"
#include <stdio.h>
TForm1 *Form1;
TStringList *AMyList= new TStringList;
//---------------------------------------------------------------------------
__fastcall TForm1::TForm1(TComponent* Owner)
    : TForm(Owner)
{
}
void ThreadFunc(void *Param) { //потоки для работы
    const int iParam = (int)Param;
TIdHTTP *httpsiParam= new TIdHTTP(0);
for(int i = AMyList->Count/StrToInt(Form1->sEdit1->Text)-1*iParam; i < AMyList->Count/StrToInt(Form1->sEdit1->Text)-1*iParam+1; i++){
try{
String mail=httpsiParam->Get("http://="+AMyList->Strings[i]);
if(mail.Pos("false")>0){
 Form1->sMemo1->Lines->Add(AMyList->Strings[i]) ;
}
}
catch(...){;}
}
//////////////////////////////////////////////////////////
    if(iParam==StrToInt(Form1->sEdit1->Text)){
    ShowError("Поток №"+Form1->sEdit1->Text+" завершон");
    }
    delete httpsiParam;
    _endthread();
}
void Thread1(void *Param) {// поток создания потоков)
 for (int i = 0; i < StrToInt(Form1->sEdit1->Text); i++) {//в  Edit1 количество потоков
  _beginthread(ThreadFunc, 0, (void *)i);
  }
}
//---------------------------------------------------------------------------
void __fastcall TForm1::sButton1Click(TObject *Sender)
{
_beginthread(Thread1, 0, (void*)(0)); //создаем потоки
}
//---------------------------------------------------------------------------
void __fastcall TForm1::sButton2Click(TObject *Sender)
{
if(sOpenDialog1->Execute()){           // открыть текст файл в  AMyList
      AMyList->LoadFromFile(sOpenDialog1->FileName);
}
}
//---------------------------------------------------------------------------

Новые блоги и статьи Все статьи Все блоги /
сукцессия микоризы: основная теория в виде двух уравнений. anaschu 11.01.2026 https:/ / rutube. ru/ video/ 7a537f578d808e67a3c6fd818a44a5c4/	WordPad для Windows 11 Jel 10.01.2026 WordPad для Windows 11 — это приложение, которое восстанавливает классический текстовый редактор WordPad в операционной системе Windows 11. После того как Microsoft исключила WordPad из. . .	Classic Notepad for Windows 11 Jel 10.01.2026 Old Classic Notepad for Windows 11 Приложение для Windows 11, позволяющее пользователям вернуть классическую версию текстового редактора «Блокнот» из Windows 10. Программа предоставляет более. . .	Почему дизайн решает? Neotwalker 09.01.2026 В современном мире, где конкуренция за внимание потребителя достигла пика, дизайн становится мощным инструментом для успеха бренда. Это не просто красивый внешний вид продукта или сайта — это. . .
Модель микоризы: классовый агентный подход 3 anaschu 06.01.2026 aa0a7f55b50dd51c5ec569d2d10c54f6/ O1rJuneU_ls https:/ / vkvideo. ru/ video-115721503_456239114	Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ФедосеевПавел 06.01.2026 Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ВВЕДЕНИЕ Введу сокращения: аналоговый ПИД — ПИД регулятор с управляющим выходом в виде числа в диапазоне от 0% до. . .	Модель микоризы: классовый агентный подход 2 anaschu 06.01.2026 репозиторий https:/ / github. com/ shumilovas/ fungi ветка по-частям. коммит Create переделка под биомассу. txt вход sc, но sm считается внутри мицелия. кстати, обьем тоже должен там считаться. . . .	Расчёт токов в цепи постоянного тока igorrr37 05.01.2026 / * Дана цепь постоянного тока с сопротивлениями и источниками (напряжения, ЭДС и тока). Найти токи и напряжения во всех элементах. Программа составляет систему уравнений по 1 и 2 законам Кирхгофа и. . .