Discussion :

[Javatator]

Bonjour,

Je suis sous ubuntu feisty et j'utilise gcc et les pthreads.
Voici mon problème j'ai un programme ou je lance 2 threads, chaque thread exécute une série de taches assez lourde et le temps d'exécution entre ces 2 threads se fait assez mal: soit l'un occupe toute les ressources pdt longtemps et l'autre attend ou vice verca.
J'aimerais que mon programme bascule rapidement d'un thread à l'autre afin de réaliser un réel pseudo traitement du code en temps réel.
Voici le canevas que j'ai utilisé :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
pthread_mutex_t mutex_cycab = PTHREAD_MUTEX_INITIALIZER;
 
static void *gestion_cycab1 (void *p_data)
{
    bool loopcycab1 = true;
    do
    {
        pthread_mutex_lock(&mutex_cycab);
        bayoccfil.Bof_display_cycab1(false);
        if (rrt.Predict_Path('1', step) == false) loopcycab1 = false;
        rrt.Move_Cycab ('1', step);
        hugrcommunication.get_Cycab_PosY('1'),2);
        pthread_mutex_unlock(&mutex_cycab);
        bayoccfil.raz_vec_occ_grid_point();
    }
    while (loopcycab1 == true);
    return NULL;
}
 
static void *gestion_cycab2 (void *p_data)
{
    bool loopcycab2 = true;
    do
    {
        pthread_mutex_lock(&mutex_cycab);
        cout<<"traitement thread 2"<<endl;
        pthread_mutex_unlock(&mutex_cycab);
    }
    while (loopcycab2 == true);
    return NULL;
}
 
int main()
{
    bayoccfil.initialisation();
    pthread_t thread_cycab1;
    pthread_t thread_cycab2;
 
    pthread_create (&thread_cycab1, NULL, gestion_cycab1, NULL);
    pthread_create (&thread_cycab2, NULL, gestion_cycab2, NULL);
 
#if 1
    pthread_join (thread_cycab1, NULL);
    pthread_join (thread_cycab2, NULL);
#endif
 
    return 0;
}

Dans cette exemple j'ai volontairement mis dans le thread2 une tache "légère", un cout. En sortie je vois que mon programme bloque sur le thread2 et ne redonne pas la main au thread1, ou tres rarement.
Comment puis-je mieux répartir les ressources processeurs entre ces 2 threads ?

merci par avance

[valefor]

Comment fais-tu pour savoir que ton programme "bloque" sur le thread 2 ? Tu te fie aux log sur la console ? Ton thread 1 fait aussi des affichages sur la console ?

As-tu essayé en :
- commentant la ligne bayoccfil.raz_vec_occ_grid_point(); ?
- mettant un simple cout<<"traitement thread 1"<<endl; dans le thread 1 ?

[Charlemagne]

En sortie je vois que mon programme bloque sur le thread2 et ne redonne pas la main au thread1, ou tres rarement.

Pour être sûr: T'as bien un système avec plusieurs processeurs ou un multi-core?

Comment puis-je mieux répartir les ressources processeurs entre ces 2 threads ?

En général on fait un thread-manager. Il faut réussir à subdiviser chaque tâche en blocs (typiquement une "granularité" de l'ordre de 100 000 instructions). Le manager distribue alors le travail de chaque bloc au fur et à mesure à l'un ou l'autre des threads dès que celui ci vient de finir un bloc.
Si par exemple une tâche prend bien moins de temps qu'une autre, ce n'est plus un problème puisque les blocs auront été réparti de manière à peu près équitable (ça dépend de la granularité) sur les threads.

[loufoque]

Dans cette exemple j'ai volontairement mis dans le thread2 une tache "légère", un cout. En sortie je vois que mon programme bloque sur le thread2 et ne redonne pas la main au thread1, ou tres rarement.

A priori, c'est tout simplement parce que la tâche du thread2 est très rapide et celle du thread1 plus longue.