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

Потоки - C++

Восстановить пароль Регистрация
 
[C++] Return
4 / 4 / 1
Регистрация: 11.09.2012
Сообщений: 110
31.07.2013, 09:27     Потоки #1
Здравствуйте.

Изначально код моей программы выглядел примерно так

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
void Thread( void* pParams )
{
//Код
}
void Thread1( void* pParams )
{
//Код
}
 
void Thread2( void* pParams )
{
//Код
}
 
void Thread3( void* pParams )
{
//Код
}
 
int main()
{
    _beginthread( Thread, 0, NULL );
    _beginthread( Thread1, 0, NULL );
_beginthread( Thread2, 0, NULL );
_beginthread( Thread3, 0, NULL );
//Код
return 0;
}

Если создать функцию


C++
1
2
3
4
void Thread( void* pParams )
{
//Код
}
И создавать потоки так

C++
1
2
3
4
5
6
7
8
int main()
{
int s;
for(s = 0; s < 3; s++)
{
_beginthread( Thread, 0, NULL );
}
return 0;
То работать будет так же как и при создании отдельных функций для каждого потока?
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
31.07.2013, 09:27     Потоки
Посмотрите здесь:

Потоки C++
Потоки с++ C++
потоки.. C++
потоки C++
потоки C++
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
Tulosba
:)
Эксперт С++
4378 / 3221 / 297
Регистрация: 19.02.2013
Сообщений: 9,044
31.07.2013, 09:39     Потоки #2
Цитата Сообщение от [C++] Return Посмотреть сообщение
То работать будет так же как и при создании отдельных функций для каждого потока?
если функция потока реентерабельна, и код во всех Thread* одинаковый, то да.
[C++] Return
4 / 4 / 1
Регистрация: 11.09.2012
Сообщений: 110
31.07.2013, 10:01  [ТС]     Потоки #3
Цитата Сообщение от Tulosba Посмотреть сообщение
если функция потока реентерабельна, и код во всех Thread* одинаковый, то да.
Проверил, но если сделать так


C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
void ThreadX( void* pParams )
{
    int X;
    for(X = 0; X < 999; X++)
    {
        cout<<"THREAD X = "<<X<<"\n";
    }
}
 
int main()
{
int s;
for(s = 0; s < 3; s++)
{
_beginthread( ThreadX, 0, NULL );
}
return 0;
}

То код выполняется так же как если бы было написано

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
void ThreadX( void* pParams )
{
    int X;
    for(X = 0; X < 999; X++)
    {
        cout<<"THREAD X = "<<X<<"\n";
    }
}
 
int main()
{
 
_beginthread( ThreadX, 0, NULL );
_beginthread( ThreadX, 0, NULL );
_beginthread( ThreadX, 0, NULL );
return 0;
}

В чем проблема?

Мне нужно, чтобы 1 функция выполнялась в разных потоках, например если мне понадобится 50 поток, не создавать же для каждого отдельную функцию
Tulosba
:)
Эксперт С++
4378 / 3221 / 297
Регистрация: 19.02.2013
Сообщений: 9,044
31.07.2013, 10:04     Потоки #4
Цитата Сообщение от [C++] Return Посмотреть сообщение
не нужно, чтобы 1 функция выполнялась в разных потоках,
Так одна и выполняется. Или Вы хотите чтобы поток 1 считал цикл от 0 до 333, поток 2 - от 334 до 666, а поток 3 - от 667 до 999?
[C++] Return
4 / 4 / 1
Регистрация: 11.09.2012
Сообщений: 110
31.07.2013, 10:11  [ТС]     Потоки #5
Цитата Сообщение от Tulosba Посмотреть сообщение
Так одна и выполняется. Или Вы хотите чтобы поток 1 считал цикл от 0 до 333, поток 2 - от 334 до 666, а поток 3 - от 667 до 999?
Нет, это реализовать было бы проще. Проблема в том, что в консоль выводится (если бы цикл был с условием X < 5)

THREAD X = 0
THREAD X = 1
THREAD X = 2
THREAD X = 3
THREAD X = 4
THREAD X = 0
THREAD X = 1
THREAD X = 2
THREAD X = 3
THREAD X = 4
THREAD X = 0
THREAD X = 1
THREAD X = 2
THREAD X = 3
THREAD X = 4


А должно выводиться так

THREAD X = 0
THREAD X = 0
THREAD X = 0
THREAD X = 1
THREAD X = 1
THREAD X = 1
THREAD X = 2
THREAD X = 2
THREAD X = 2
THREAD X = 3
THREAD X = 3
THREAD X = 3
THREAD X = 4
THREAD X = 4
THREAD X = 4


Вот в чем проблема, они выполняется в какой то непонятной очереди а не одновременно
korvin_
 Аватар для korvin_
1326 / 1097 / 160
Регистрация: 28.04.2012
Сообщений: 3,926
31.07.2013, 10:49     Потоки #6
Добавь в цикл в ThreadX задержку на 500 миллисекунд, например.
Cerbery-San
1 / 1 / 0
Регистрация: 23.07.2013
Сообщений: 24
31.07.2013, 10:53     Потоки #7
Странно, я скопировал ваш код в VS 2008
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
#include <iostream>
#include <process.h>
 
void ThreadX( void* pParams )
{
    int X;
    for(X = 0; X < 5; X++)
    {
        std::cout<<"THREAD X = "<<X<<"\n";
    }
}
 
int main()
{
    int s;
    for(s = 0; s < 3; s++)
    {
        _beginthread( ThreadX, 0, NULL );
    }
    std::cin.get();
    return 0;
}
вот что выдало

THREAD X = THREAD X = THREAD X = 0
THREAD X = 00
THREAD X =
1
THREAD X = 2
THREAD X = THREAD X = 13
THREAD X = 4

THREAD X = 1
THREAD X = 2
THREAD X = 2
THREAD X = 3
THREAD X = 4
3
THREAD X = 4
Tulosba
:)
Эксперт С++
4378 / 3221 / 297
Регистрация: 19.02.2013
Сообщений: 9,044
31.07.2013, 11:04     Потоки #8
Цитата Сообщение от Cerbery-San Посмотреть сообщение
вот что выдало
Цитата Сообщение от [C++] Return Посмотреть сообщение
А должно выводиться так
Выводить может вообще как угодно. Так как никакой синхронизации между потоками нет. Как система диспетчеризации ОС решит, такому потоку квант времени и выделится.

Добавлено через 1 минуту
Цитата Сообщение от korvin_ Посмотреть сообщение
Добавь в цикл в ThreadX задержку на 500 миллисекунд,
Так бы все проги и писались, ога.
SatanaXIII
Супер-модератор
Эксперт С++
 Аватар для SatanaXIII
5548 / 2562 / 233
Регистрация: 01.11.2011
Сообщений: 6,333
Завершенные тесты: 1
31.07.2013, 11:09     Потоки #9
Cerbery-San, тут в соседнем разделе этот момент рассматривали. Только в профиль.
korvin_
 Аватар для korvin_
1326 / 1097 / 160
Регистрация: 28.04.2012
Сообщений: 3,926
31.07.2013, 11:27     Потоки #10
Цитата Сообщение от Tulosba Посмотреть сообщение
Так бы все проги и писались, ога.
Исключительно в целях убеждения.
[C++] Return
4 / 4 / 1
Регистрация: 11.09.2012
Сообщений: 110
31.07.2013, 11:54  [ТС]     Потоки #11
Тут я ошибся

Неправильно
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
void ThreadX( void* pParams )
{
    int X;
    for(X = 0; X < 999; X++)
    {
        cout<<"THREAD X = "<<X<<"\n";
    }
}
 
int main()
{
 
_beginthread( ThreadX, 0, NULL );
_beginthread( ThreadX, 0, NULL );
_beginthread( ThreadX, 0, NULL );
return 0;
}
Как должно было быть

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
void ThreadX( void* pParams )
{
    int X;
    for(X = 0; X < 999; X++)
    {
        cout<<"THREAD X = "<<X<<"\n";
    }
}
 
int main()
{
ThreadX(NULL);
ThreadX(NULL);
ThreadX(NULL);
 
return 0;
}
Добавлено через 1 минуту
Цитата Сообщение от Tulosba Посмотреть сообщение
Выводить может вообще как угодно. Так как никакой синхронизации между потоками нет. Как система диспетчеризации ОС решит, такому потоку квант времени и выделится.

Какими еще способами можно проверить, что функция выполняется в разных потоках?
Tulosba
:)
Эксперт С++
4378 / 3221 / 297
Регистрация: 19.02.2013
Сообщений: 9,044
31.07.2013, 12:03     Потоки #12
Цитата Сообщение от [C++] Return Посмотреть сообщение
Какими еще способами можно проверить, что функция выполняется в разных потоках?
Диспетчером задач. А вообще - выводите в цикле какое-то уникальное значение для каждого потока, например threadId. Ну, и кол-во итераций цикла, конечно, надо сделать посущественнее.
[C++] Return
4 / 4 / 1
Регистрация: 11.09.2012
Сообщений: 110
31.07.2013, 12:14  [ТС]     Потоки #13
Цитата Сообщение от Tulosba Посмотреть сообщение
Диспетчером задач. А вообще - выводите в цикле какое-то уникальное значение для каждого потока, например threadId. Ну, и кол-во итераций цикла, конечно, надо сделать посущественнее.
Можно подробней как проверять через диспечер задач?

Замена threadId так пойдет?
Как задать потоку значение?
Я при создании потока вызываю функцию с параметром равным циклу
C++
1
2
3
4
5
int s;
for(s = 0; s < 3; s++)
{
_beginthread( Thread, 0, (void*)s );
}
MoreAnswers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
31.07.2013, 14:08     Потоки
Еще ссылки по теме:

Потоки C++
Потоки C++
Потоки C++

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

Или воспользуйтесь поиском по форуму:
Tulosba
:)
Эксперт С++
4378 / 3221 / 297
Регистрация: 19.02.2013
Сообщений: 9,044
31.07.2013, 14:08     Потоки #14
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
#include <iostream>
#include <process.h>
 
void func( void* data )
{
    int id = *static_cast<int*>(data);
    for( int i=0; i<1000000; ++i )
    {
        std::cout << id << std::endl;
    }
}
 
int main ()
{
   for( int s=0; s<3; ++s )
   {
      _beginthread( func, 0, &s );
   }
   return 0;
}
Цитата Сообщение от [C++] Return Посмотреть сообщение
Можно подробней как проверять через диспечер задач?
Для начала не помешает поставить ProcessExplorer А дальше смотреть кол-во потоков для процесса:
Миниатюры
Потоки  
Yandex
Объявления
31.07.2013, 14:08     Потоки
Ответ Создать тему
Опции темы

Текущее время: 06:18. Часовой пояс GMT +3.
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2016, vBulletin Solutions, Inc.
Рейтинг@Mail.ru