mirror of
https://sourceware.org/git/glibc.git
synced 2025-07-29 11:41:21 +03:00
Update.
* sysdeps/unix/sysv/linux/sparc/sparc64/bits/types.h: Add __ino64_t definition.
This commit is contained in:
@ -17,15 +17,15 @@ void * process(void * arg)
|
||||
return NULL;
|
||||
}
|
||||
|
||||
int main()
|
||||
int main(void)
|
||||
{
|
||||
int retcode;
|
||||
pthread_t th_a, th_b;
|
||||
void * retval;
|
||||
|
||||
retcode = pthread_create(&th_a, NULL, process, "a");
|
||||
retcode = pthread_create(&th_a, NULL, process, (void *) "a");
|
||||
if (retcode != 0) fprintf(stderr, "create a failed %d\n", retcode);
|
||||
retcode = pthread_create(&th_b, NULL, process, "b");
|
||||
retcode = pthread_create(&th_b, NULL, process, (void *) "b");
|
||||
if (retcode != 0) fprintf(stderr, "create b failed %d\n", retcode);
|
||||
retcode = pthread_join(th_a, &retval);
|
||||
if (retcode != 0) fprintf(stderr, "join a failed %d\n", retcode);
|
||||
@ -33,4 +33,3 @@ int main()
|
||||
if (retcode != 0) fprintf(stderr, "join b failed %d\n", retcode);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
@ -97,7 +97,7 @@ void * consumer(void * data)
|
||||
return NULL;
|
||||
}
|
||||
|
||||
int main()
|
||||
int main(void)
|
||||
{
|
||||
pthread_t th_a, th_b;
|
||||
void * retval;
|
||||
@ -111,6 +111,3 @@ int main()
|
||||
pthread_join(th_b, &retval);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
@ -1,6 +1,7 @@
|
||||
/* Multi-thread searching.
|
||||
Illustrates: thread cancellation, cleanup handlers. */
|
||||
|
||||
#include <errno.h>
|
||||
#include <stdio.h>
|
||||
#include <unistd.h>
|
||||
#include <stdlib.h>
|
||||
@ -19,9 +20,7 @@ pthread_t threads[NUM_THREADS];
|
||||
pthread_mutex_t lock;
|
||||
int tries;
|
||||
|
||||
int main(argc, argv)
|
||||
int argc;
|
||||
char ** argv;
|
||||
int main(int argc, char ** argv)
|
||||
{
|
||||
int i;
|
||||
int pid;
|
||||
@ -31,14 +30,14 @@ int main(argc, argv)
|
||||
printf("Searching for the number = %d...\n", pid);
|
||||
|
||||
/* Initialize the mutex lock */
|
||||
pthread_mutex_init(&lock, NULL);
|
||||
pthread_mutex_init(&lock, NULL);
|
||||
|
||||
/* Create the searching threads */
|
||||
for (i=0; i<NUM_THREADS; i++)
|
||||
pthread_create(&threads[i], NULL, search, (void *)pid);
|
||||
|
||||
/* Wait for (join) all the searching threads */
|
||||
for (i=0; i<NUM_THREADS; i++)
|
||||
for (i=0; i<NUM_THREADS; i++)
|
||||
pthread_join(threads[i], NULL);
|
||||
|
||||
printf("It took %d tries to find the number.\n", tries);
|
||||
@ -47,7 +46,7 @@ int main(argc, argv)
|
||||
return 0;
|
||||
}
|
||||
|
||||
/* This is the cleanup function that is called
|
||||
/* This is the cleanup function that is called
|
||||
when the threads are cancelled */
|
||||
|
||||
void print_it(void *arg)
|
||||
@ -59,7 +58,7 @@ void print_it(void *arg)
|
||||
tid = pthread_self();
|
||||
|
||||
/* Print where the thread was in its search when it was cancelled */
|
||||
printf("Thread %lx was canceled on its %d try.\n", tid, *try);
|
||||
printf("Thread %lx was canceled on its %d try.\n", tid, *try);
|
||||
}
|
||||
|
||||
/* This is the search routine that is executed in each thread */
|
||||
@ -82,20 +81,20 @@ void *search(void *arg)
|
||||
ntries = 0;
|
||||
|
||||
/* Set the cancellation parameters --
|
||||
- Enable thread cancellation
|
||||
- Enable thread cancellation
|
||||
- Defer the action of the cancellation */
|
||||
|
||||
pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
|
||||
pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, NULL);
|
||||
|
||||
/* Push the cleanup routine (print_it) onto the thread
|
||||
cleanup stack. This routine will be called when the
|
||||
cleanup stack. This routine will be called when the
|
||||
thread is cancelled. Also note that the pthread_cleanup_push
|
||||
call must have a matching pthread_cleanup_pop call. The
|
||||
push and pop calls MUST be at the same lexical level
|
||||
push and pop calls MUST be at the same lexical level
|
||||
within the code */
|
||||
|
||||
/* Pass address of `ntries' since the current value of `ntries' is not
|
||||
/* Pass address of `ntries' since the current value of `ntries' is not
|
||||
the one we want to use in the cleanup function */
|
||||
|
||||
pthread_cleanup_push(print_it, (void *)&ntries);
|
||||
@ -118,7 +117,7 @@ void *search(void *arg)
|
||||
printf("Thread %lx found the number!\n", tid);
|
||||
|
||||
/* Cancel all the other threads */
|
||||
for (j=0; j<NUM_THREADS; j++)
|
||||
for (j=0; j<NUM_THREADS; j++)
|
||||
if (threads[j] != tid) pthread_cancel(threads[j]);
|
||||
|
||||
/* Break out of the while loop */
|
||||
@ -141,4 +140,3 @@ void *search(void *arg)
|
||||
pthread_cleanup_pop(0);
|
||||
return((void *)0);
|
||||
}
|
||||
|
||||
|
@ -40,7 +40,7 @@ static void str_alloc_destroy_accu(void * accu);
|
||||
|
||||
/* Thread-safe version of str_accumulate */
|
||||
|
||||
char * str_accumulate(char * s)
|
||||
char * str_accumulate(const char * s)
|
||||
{
|
||||
char * accu;
|
||||
|
||||
@ -97,8 +97,8 @@ int main(int argc, char ** argv)
|
||||
pthread_t th1, th2;
|
||||
|
||||
res = str_accumulate("Result of ");
|
||||
pthread_create(&th1, NULL, process, "first");
|
||||
pthread_create(&th2, NULL, process, "second");
|
||||
pthread_create(&th1, NULL, process, (void *) "first");
|
||||
pthread_create(&th2, NULL, process, (void *) "second");
|
||||
res = str_accumulate("initial thread");
|
||||
printf("Thread %lx: \"%s\"\n", pthread_self(), res);
|
||||
pthread_join(th1, NULL);
|
||||
|
@ -86,7 +86,7 @@ void * consumer(void * data)
|
||||
return NULL;
|
||||
}
|
||||
|
||||
int main()
|
||||
int main(void)
|
||||
{
|
||||
pthread_t th_a, th_b;
|
||||
void * retval;
|
||||
|
38
linuxthreads/Examples/ex6.c
Normal file
38
linuxthreads/Examples/ex6.c
Normal file
@ -0,0 +1,38 @@
|
||||
#include <errno.h>
|
||||
#include <stdio.h>
|
||||
#include <string.h>
|
||||
#include <pthread.h>
|
||||
|
||||
void *
|
||||
test_thread (void *v_param)
|
||||
{
|
||||
return NULL;
|
||||
}
|
||||
|
||||
int
|
||||
main (void)
|
||||
{
|
||||
unsigned long count;
|
||||
|
||||
for (count = 0; count < 2000; ++count)
|
||||
{
|
||||
pthread_t thread;
|
||||
int status;
|
||||
|
||||
status = pthread_create (&thread, NULL, test_thread, NULL);
|
||||
if (status != 0)
|
||||
{
|
||||
printf ("status = %d, count = %lu: %s\n", status, count,
|
||||
strerror (errno));
|
||||
return 1;
|
||||
}
|
||||
else
|
||||
{
|
||||
printf ("count = %lu\n", count);
|
||||
}
|
||||
/* pthread_detach (thread); */
|
||||
pthread_join (thread, NULL);
|
||||
usleep (50);
|
||||
}
|
||||
return 0;
|
||||
}
|
Reference in New Issue
Block a user