Странная работа потока

@iiieoi · 18.06.2015, 23:55. **Показов** 825. **Ответов** 4

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

Вообщем не могу понять в чем дело, есть программа:

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
//---------------------------------------------------------------------------
void __fastcall TForm1::Execute() {
        TGenThread *GenThread = new TGenThread(true);
        GenThread->Priority = tpHigher;
        GenThread->Resume();
        Sleep(400);
        for ( int i = 1 ; i < 5 ; ++i ) {
                //GenThread->Resume();
                Form1->Memo1->Lines->Add(IntToStr(i));
        }
        GenThread->Terminate();
        GenThread->Resume();
}
//---------------------------------------------------------------------------
 
void __fastcall TForm1::Button1Click(TObject *Sender)
{
Execute();        
}

и поток :

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
void __fastcall TGenThread::Execute()
{
        while(1) {
                if(Terminated) break;
                Synchronize(Update);
                Suspend();
        }
}
//---------------------------------------------------------------------------
void  __fastcall TGenThread::Update()
{
        Form1->Memo1->Lines->Add( "yyy" );
}

ожидал получить в результате чтото вроде:

yyy
1
2
3
4

а получил:

1
2
3
4
yyy

почему поток срабатывает после цикла? хотя специально поставил его вначале и даже сделал sleep?
изначально необходимо было чтобы поток запускался в цикле, а после выполнения приостанавливался до следующей итерации цикла, но результат был аналогичен (1,2,3,4,yyy)
версия билдера 6

@Fulcrum_013 · 19.06.2015, 00:13

Synchronize causes the call specified by AMethod to be executed using the main thread, thereby avoiding multithread conflicts

- т.е. TGenThread::Update() отрабатывает в главном потоке а не в потоке GenThread;

@_Dimon_ · 19.06.2015, 05:07

интересный способ запуска потока
и Sleep(400) работает не в потоке

сделай функции работы с потоком (обертки), не принадлежащие классу потока, но в модуле потока
и безопасно вызывай их с любой формы, но Synchronize в потоке нужно делать полюбому

Добавлено через 17 минут

C++
1
2
3
4
5
6
7
8
9
10
11
12
void __fastcall TForm1::Execute() {
        TGenThread *GenThread = new TGenThread(true);
        GenThread->Priority = tpHigher;
        GenThread->Resume();  // ???? у  тебя и так TGenThread(true), то есть создавай TGenThread(false);
        Sleep(400);  // зачем ?
        for ( int i = 1 ; i < 5 ; ++i ) {
                //GenThread->Resume();
                Form1->Memo1->Lines->Add(IntToStr(i)); // это нужно делать через Synchronize 
        }
        GenThread->Terminate();
        GenThread->Resume(); // это что? после убийства потока нет смысла его дергать
}

@Appi · 19.06.2015, 18:14

Слушай, а можешь кинуть пример создания данного потока. Типо

поток {
//Тут описывается инструкция функции которая будет работать в потоке
}

Где-то в программе {
Запустили поток
}

@iiieoi · 20.06.2015, 02:01 **[ТС]**

Переписал чутка прогу, теперь при нажатии кнопки создаются 3 потока, один из которых является поставщиком данных для двух других, которые обрабатывают эти данные и результаты заносят в список listData.

Вообщем вот что получилось:
Основной поток:

Кликните здесь для просмотра всего текста

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
//---------------------------------------------------------------------------
#include <list.h>
#include <vcl.h>
#pragma hdrstop
 
#include "Thread.h"
#include "ClassThread.h"
//---------------------------------------------------------------------------
#pragma package(smart_init)
#pragma resource "*.dfm"
TForm1 *Form1;
CRITICAL_SECTION cs;
TGenThread *MainThread;
TGenThread *GenThread;
TGenThread *GenThread1;
//---------------------------------------------------------------------------
__fastcall TForm1::TForm1(TComponent* Owner)
        : TForm(Owner)
{
        InitializeCriticalSection(&cs);
 
}
//---------------------------------------------------------------------------
void __fastcall TForm1::CreateThread() {
        terminate = 0; // сбрасываем флаг завешения работы
        //создаем три потока
        MainThread = new TGenThread(true);
        GenThread = new TGenThread(true);
        GenThread1 = new TGenThread(true);
* * * * //инициализируем их
        MainThread->Priority = tpHigher;
        MainThread->Init(0);
        GenThread->Priority = tpHigher;
        GenThread->Init(1);
        GenThread1->Priority = tpHigher;
        GenThread1->Init(2);
* * * * //запускаем главный поток (поставщик данных для двух других)
        MainThread->Resume();
}
//---------------------------------------------------------------------------
void __fastcall TForm1::Execute() {
 
        for ( int i = 1 ; i < 5 ; ++i ) {
                        flag = 0; // сброс флага завершенных потоками вычислений
                        it = i; // заносим в глобальную переменную новые данные для обработки
                        GenThread->Resume(); // запускаем поток 1
                        GenThread1->Resume(); // запускаем поток 2
                        MainThread->Suspend(); // останавливаем главный поток
        }
        terminate = 1; // выставляем флаг завершения работы
        GenThread->Resume(); // запускаем выход цикла в поток 1 
        GenThread1->Resume(); // запускаем выход цикла в поток 2  
}
//---------------------------------------------------------------------------
void __fastcall TForm1::Generation() {
                        while (!terminate) { 
                        EnterCriticalSection(&cs);
                                listData.push_back(it+10); // обработка данных
                                flag++; // увеличиваем флаг отработанных потоков
                        LeaveCriticalSection(&cs);
                        if ( flag == 2 ) MainThread->Resume(); // проверяем флаг, если этот поток завершил вычисления последним, то запускаем главный поток
                        GenThread->Suspend(); // останавливаем поток 1
                        }
}
//---------------------------------------------------------------------------
void __fastcall TForm1::Generation1() {
                        while (!terminate) {
                        EnterCriticalSection(&cs);
                                listData.push_back(it+100); // обработка данных
                                flag++;  // увеличиваем флаг отработанных потоков
                        LeaveCriticalSection(&cs);
                        if ( flag == 2 ) MainThread->Resume();  // проверяем флаг, если этот поток завершил вычисления последним, то запускаем главный поток
                        GenThread1->Suspend(); // останавливаем поток 1
                        }
}
//---------------------------------------------------------------------------
 
void __fastcall TForm1::Button1Click(TObject *Sender)
{
        CreateThread(); // создание потоков по нажатию на кнопке
}
//---------------------------------------------------------------------------
 
void __fastcall TForm1::Button2Click(TObject *Sender)
{
        Memo1->Lines->Add("-----");
        for ( list<int>::iterator it = listData.begin() ; it != listData.end() ; ++it ) {
                Memo1->Lines->Add(*it);
        }
}
//---------------------------------------------------------------------------
 
void __fastcall TForm1::FormClose(TObject *Sender, TCloseAction &Action)
{
        DeleteCriticalSection(&cs);
}
//---------------------------------------------------------------------------

Потоки обработки:

Кликните здесь для просмотра всего текста

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
//---------------------------------------------------------------------------
void __fastcall TGenThread::Execute()
{
        FreeOnTerminate = true; //флаг освобождения памяти при завершении потока
        // запуск функции в потоке в зависимости от ключа инициализации
        if (NumF == 0) {
                Form1->Execute(); //
        } else if (NumF == 1) {
                Form1->Generation();
        } else if (NumF == 2) {
                Form1->Generation1();
        } else {};
}
 
//---------------------------------------------------------------------------
void  __fastcall TGenThread::Init( int NumF_)
{
        NumF = NumF_; // Создаем ключ для запуска
}

Добавлено через 16 минут

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

интересный способ запуска потока
и Sleep(400) работает не в потоке

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

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

GenThread->Resume(); *// ???? у *тебя и так TGenThread(true), то есть создавай TGenThread(false);

TGenThread(true) - создает поток в приоставновленом состоянии, а не наоборот

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

Form1->Memo1->Lines->Add(IntToStr(i)); // это нужно делать через Synchronize

Это строка находится в TForm1::Execute() тоесть выполняется в основном потоке программы, никаких синхронизаций там нет.

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

GenThread->Terminate();
* * * * GenThread->Resume(); // это что? после убийства потока нет смысла его дергать

GenThread->Terminate() не останавливает поток, а выставляет флаг, что поток можно завершить, учитывая что в этот момент поток находится на паузе, его нужно возобновить чтоб эта строка отработала.

Новые блоги и статьи Все статьи Все блоги /
Перемещение выделенных строк ТЧ из одного документа в другой 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. В качестве источника данных. . .

@Appi 20 / 20 / 7 Регистрация: 18.02.2015 Сообщений: 304
	19.06.2015, 18:14
	Слушай, а можешь кинуть пример создания данного потока. Типо поток { //Тут описывается инструкция функции которая будет работать в потоке } Где-то в программе { Запустили поток } 0