Sponsored Content
Top Forums Programming How to use pipe() in multiple threads? Post 26331 by chenhao_no1 on Thursday 15th of August 2002 09:27:50 AM
Old 08-15-2002
example is blow :


#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <pthread.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/socket.h>

int fd[2];

void open_pipe(void)
{
/*
** Notice here .It is the same as pipe()
*/
if(socketpair(PF_UNIX,SOCK_STREAM,0,fd) < 0)
{
fprintf(stderr,"File : %s , Line : %d , socketpair error:",
__FILE__,
__LINE__);
perror("");
abort();
}
}

void *do_task(void *arg)
{
int n;

printf("\t come into thread \n");

n = read(fd[0],(void *) &iValue,sizeof(iValue));
printf("\t child1 ,Line = %d \n", iValue);

return (void *) NULL;
}

void main(void)
{
int iRetSts,iValue;
pthread_t iThreadId;
pthread_attr_t vThreadAttr;

open_pipe();

pthread_attr_init(&vThreadAttr);
pthread_create(&iThreadId,NULL,do_task,(void *)NULL);

iRetSts = write(fd[1],(void *) &iValue,sizeof(iValue));
if(iRetSts == -1)
{
fprintf(stderr,"File : %s , Line : %d , write failed \n",
__FILE__,
__LINE__);
perror("");
}
}


please refer to manpage of socketpair() function
 

10 More Discussions You Might Find Interesting

1. Programming

synchronizing multiple threads in unix

hi all! I wanted to know how to synchronize multiple threads in unix It would be better if someone give some code samples Thanx (1 Reply)
Discussion started by: bankpro
1 Replies

2. IP Networking

How to choose Multiple process or Multiple threads?

Hi All, Please explain me when i have to use multiple process and when I have to use Multiple threads? Please give me an example.It will be very helpful for me. Thanks in advance. (0 Replies)
Discussion started by: ashleykumar
0 Replies

3. UNIX for Dummies Questions & Answers

Threads with pipe and select?

Hi. I just found this site while searching for some info on a problem and thought I'd see if anyone else knows the answer. I have two threads that are connected by a pipe. Thread A can write to the pipe and Thread B can read the data from the pipe. My problem is that when I use select() in... (3 Replies)
Discussion started by: willil
3 Replies

4. Shell Programming and Scripting

Spawning multiple threads in Unix

Hi, I need to spawn mutilpe threads , each invoking a different set of shell scripts, in parallel. What would be the best way to do that. Any sample script would greatly help. I am a novice at Unix so any help is much appreciated. Thanks (5 Replies)
Discussion started by: neeto
5 Replies

5. UNIX for Advanced & Expert Users

Which IPC between multiple threads will suit most in scenerio?

Hi Friends, I am designing a solution for a problem: in which my master thread receiving network message and processing them, during processing of each message i need to communicate remote database (that is actually a separate external module)that cause a delay of arount 2 second (), After... (1 Reply)
Discussion started by: johnray31
1 Replies

6. Programming

File access from multiple processes or threads?

Hi, Can anyone give me any idea when multiple processes access a file (like opening it, modifying it etc.) how can the synchronization can be done if they can access the same file at any time? How can this scenario is different from when multiple threads access a same file, modifying it etc- in... (7 Replies)
Discussion started by: sanzee
7 Replies

7. UNIX for Dummies Questions & Answers

Copy files in Multiple Threads

Hello all, I have a directory of files of varying sizes. I want to copy all these files in n number of threads to another directory such that each copy set is more or less the same size. Example : Say /mydirA It has around say 23 files of various sizes. Number of copy... (0 Replies)
Discussion started by: samoo
0 Replies

8. Shell Programming and Scripting

How to make this run in multiple threads

Hi, I have a list of URLs in a csv file which I'm checking for page status. It just prints the URL and the status as output. This works perfectly fine. I'm looking to run this in multiple threads to make this process faster. I'm pretty new to Perl and I managed to complete this. It would be... (9 Replies)
Discussion started by: kzenthil
9 Replies

9. Shell Programming and Scripting

How to start multiple threads in Solaris?

Hello, In a unix Solaris environment, (for simulation) how to start multiple threads (as Light Weight Process, not background process)? thanks, J. (7 Replies)
Discussion started by: seafan
7 Replies

10. Shell Programming and Scripting

Need to create multiple threads

Hi , i need to run multiple scripts parallely ,on my server....i have 8 cpus . planning to run minimum of 6 scripts paralley ....could you please suggest someone . thanks in advance , (3 Replies)
Discussion started by: Huvan
3 Replies
ERROR(3)						     Linux Programmer's Manual							  ERROR(3)

NAME
error, error_at_line, error_message_count, error_on_per_line, error_print_progname - glibc error reporting functions SYNOPSIS
#include <error.h> void error(int status, int errnum, const char *format, ...); void error_at_line(int status, int errnum, const char *filename, unsigned int linenum, const char *format, ...); extern unsigned int error_message_count; extern int error_one_per_line; extern void (* error_print_progname) (void); DESCRIPTION
error() is a general error reporting function. It flushes stdout, and then outputs to stderr the program name, a colon and a space, the message specified by the printf(3)-style format string format, and, if errnum is nonzero, a second colon and a space followed by the string given by perror(errnum). Any arguments required for format should follow format in the argument list. The output is terminated by a new- line character. The program name printed by error() is the value of the global variable program_invocation_name(3). program_invocation_name initially has the same value as main()'s argv[0]. The value of this variable can be modified to change the output of error(). If status has a nonzero value, then error() calls exit(3) to terminate the program using the given value as the exit status. The error_at_line() function is exactly the same as error(), except for the addition of the arguments filename and linenum. The output produced is as for error(), except that after the program name are written: a colon, the value of filename, a colon, and the value of linenum. The preprocessor values __LINE__ and __FILE__ may be useful when calling error_at_line(), but other values can also be used. For example, these arguments could refer to a location in an input file. If the global variable error_one_per_line is set nonzero, a sequence of error_at_line() calls with the same value of filename and linenum will result in only one message (the first) being output. The global variable error_message_count counts the number of messages that have been output by error() and error_at_line(). If the global variable error_print_progname is assigned the address of a function (i.e., is not NULL), then that function is called instead of prefixing the message with the program name and colon. The function should print a suitable string to stderr. CONFORMING TO
These functions and variables are GNU extensions, and should not be used in programs intended to be portable. SEE ALSO
err(3), errno(3), exit(3), perror(3), program_invocation_name(3), strerror(3) COLOPHON
This page is part of release 3.25 of the Linux man-pages project. A description of the project, and information about reporting bugs, can be found at http://www.kernel.org/doc/man-pages/. GNU
2006-04-25 ERROR(3)
All times are GMT -4. The time now is 07:22 AM.
Unix & Linux Forums Content Copyright 1993-2022. All Rights Reserved.
Privacy Policy