Solved

pthread sync

Posted on 2001-07-19
8
866 Views
Last Modified: 2008-01-09
I have an application that is getting bigger and bigger and application threads are running wild.  someone told me to use semaphore to syncronize them.  
for instance,  i have thread1, thread2, thread3, thread4, ..... thread22.
i want thread2 to wait on 1 and I want thread 3 to wait on thread2. I want threads 15-22 to wait on thread7 , then thread8 wait on thread22   got the picture?, why make them threads, because each one is responsible for a specific HW.
my questions are:
-->could I use semaphore for this, or is there a better way
------->if semaphore will do the job, is there somewhere i can learn they quick, how-to, tutorial, examples, etc etc?
-------> if ! what can I use?

ps.  the order of threads might change, I could stop thread2, then thread3 will wait for thread1.
0
Comment
Question by:ragaMuffin
8 Comments
 
LVL 8

Expert Comment

by:mnashadka
ID: 6300630
If you're keeping track of the thread id's, you might want to try pthread_join.
0
 

Author Comment

by:ragaMuffin
ID: 6305521
that is not what I'm looking for
0
 

Author Comment

by:ragaMuffin
ID: 6305525
It should be like an interrupt, each device, or thread get a slice of the 20 mils, so all threads must run once, during an interval of 20 milliseconds
0
Master Your Team's Linux and Cloud Stack!

The average business loses $13.5M per year to ineffective training (per 1,000 employees). Keep ahead of the competition and combine in-person quality with online cost and flexibility by training with Linux Academy.

 

Author Comment

by:ragaMuffin
ID: 6305526
and pthread_join, waits until the thread exits, my threads are running still.  so you see I'm looking for a scheduler.
sorry for the multiple comments.
0
 
LVL 2

Expert Comment

by:nahumd
ID: 6305785
Yes you can use semaphore (mutex) to synchronize the threads as you wanted.
Use pthread_mutex_init to create the mutex, mutex_lock and mutex_unlock to signal and wait for a critical section.
0
 

Author Comment

by:ragaMuffin
ID: 6306282
nahumd,
can you point me somewhere where there is an example or a how-to document, other than man pages?
0
 
LVL 5

Expert Comment

by:garboua
ID: 6306293
/* This example is copied from */
/* http://www.coe.uncc.edu/~abw/parallel/pthreads/pthreads.html */
/* It illustrates the idea of shared memory programming */

/* Comments: the behavior of this program on Solaris 2.7 is quite different from that of Red Hat Linux 6.2. On Solaris, the program acted incorrectly while the outcome on Red Hat Linux 6.2 was as expected. X.M. */

#include <pthread.h>  
#include <stdio.h>
#define MAX 10
#define MAX_COUNT 15

void * increment(int *id);
void * watch(int *id);

int count =0;
pthread_mutex_t count_mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t count_max = PTHREAD_COND_INITIALIZER;
int thread_id[3]  = {0,1,2};

main()
{
        int i;
        /* define the type to be pthread */
       
        pthread_t thread[3];
        /* create 3 threads*/
        pthread_create(&thread[2], NULL, (void *)watch, &thread_id[2]);
        pthread_create(&thread[0], NULL, (void *)increment, &thread_id[0]);
        pthread_create(&thread[1], NULL, (void *)increment, &thread_id[1]);
       
        for(i=0; i< 3 ; i++)
        {
                pthread_join(thread[i], NULL);
        }
}

void * watch(int *id)
{
        /* lock the variable */
        pthread_mutex_lock(&count_mutex);
        while(count <= MAX_COUNT)
        {
                /* using the condition variable for waiting for the event */
                pthread_cond_wait(&count_max, &count_mutex);
                printf("Inside the watch() and the value is %d\n", count);
          fflush(stdout);
        }
        /*unlock the variable*/
        pthread_mutex_unlock(&count_mutex);
}

void * increment(int *id)
{
     int i;
     for(i=0; i< MAX ; i++)
     {
          /* lock the variable */
          pthread_mutex_lock(&count_mutex);
          count++;
          printf("in increment counter by threadof id :%d, and count: %d\n",*id, count);
       fflush(stdout);
          /* for the condition notify the thread */
          pthread_cond_signal(&count_max);
          /*unlock the variable*/
          pthread_mutex_unlock(&count_mutex);
          sleep(rand()%2);
     }
}
This is give you an idea on how to use mutex
0
 
LVL 5

Accepted Solution

by:
garboua earned 100 total points
ID: 6306303
for more illustration and full documentation, read the C programming mini course sections about semaphores and pthread.

threads:
http://docs.linux.cz/c_marshall/node29.html#SECTION002900000000000000000
IPC SEMAPHORE
http://docs.linux.cz/c_marshall/node26.html#SECTION002600000000000000000
0

Featured Post

Free Tool: Site Down Detector

Helpful to verify reports of your own downtime, or to double check a downed website you are trying to access.

One of a set of tools we are providing to everyone as a way of saying thank you for being a part of the community.

Question has a verified solution.

If you are experiencing a similar issue, please ask a related question

Have you ever been frustrated by having to click seven times in order to retrieve a small bit of information from the web, always the same seven clicks, scrolling down and down until you reach your target? When you know the benefits of the command l…
The purpose of this article is to demonstrate how we can upgrade Python from version 2.7.6 to Python 2.7.10 on the Linux Mint operating system. I am using an Oracle Virtual Box where I have installed Linux Mint operating system version 17.2. Once yo…
Established in 1997, Technology Architects has become one of the most reputable technology solutions companies in the country. TA have been providing businesses with cost effective state-of-the-art solutions and unparalleled service that is designed…
With Secure Portal Encryption, the recipient is sent a link to their email address directing them to the email laundry delivery page. From there, the recipient will be required to enter a user name and password to enter the page. Once the recipient …

828 members asked questions and received personalized solutions in the past 7 days.

Join the community of 500,000 technology professionals and ask your questions.

Join & Ask a Question