운영체제/ 프로세스

java program

long state; /* 프로세스 상태 */ struct sched_entity se; /* 스케쥴링 정보 */ struct task_struct *parent; /* 이 프로세스의 부모 */ struct list_head children; /* 이 프로세스의 자식들 */ struct files_struc *files; /* 오픈 파일 */ struct mm_struct *mm; /* 이 프로세스의 주소 공간 */

current->state = new_state;

ps -el

#include <sys/types.h> #include <unistd.h> main(int argc, char *argv[]) { int pid; /* 새 프로세스를 생성한다(fork) */ pid = fork(); if (pid < 0) { /* 오류가 발생했음 */ fprintf(stderr, "Fork Failed"); return 1; } else if (pid == 0) { /* 자식 프로세스 */ execlp("/bins/ls", "ls", NULL); } else { /* 부모 프로세스 */ /* 부모가 자식이 완료되기를 기다림 */ wait(NULL); printf("Child Complete"); } return 0; }

#include <stdio.h> #include <window.h> int main(VOID) { STARTUPINFO si; PROCESS_INFORMATION pi; // 메모리 할당 ZeroMemory(&si, sizeof(si)); si.cb = sizeof(si); ZeroMemory(&pi, sizeof(pi)); // 자식 프로세스 생성 if (!CreateProcess(NULL, // 명령어 라인 사용 "C:\\WINDOWS\\system32\mspaint.exe", // 명령어 라인 NULL, // 프로세스를 상속하지 말 것 NULL, // 스레드 핸들을 상속하지 말 것 FALSE, // 핸들 상속 disable 0, // 생성 플래그 없음 NULL, // 부모 환경 블록 사용 NULL, // 부모 프로세스가 존재하는 디렉터리 사용 &si, &pi)) { fprintf(stderror, "Create Process Failed"); return -1; } // 부모 프로세스가 자식 프로세스가 끝나기를 기다림 WaitForSingleObject(pi.hProcess, INFINITE); printf("Child Complete"); // 핸들 닫기 CloseHandle(pi.hProcess); CloseHandle(pi.hThread); }

/* 1인 상태로 exit */ exit(1);

pid_t pid; int status; pid = wait(&status);

#define BUFFER_SIZE 10 typedef struct { ... } item; item buffer[BUFFER_SIZE]; int in = 0; int out = 0;

// 공유 메모리를 사용한 생산자 프로세스 item_next_Produced; while (true) { /* next_Produced에 생산된 item 저장 */ while (((in + 1) % BUFFER_SIZE == out) ; /* 아무 일도 안 함 */ buffer[in] = next_Produced; in = (in + 1) % BUFFER_SIZE; }

// 공유 메모리를 사용한 소비자 프로세스 item_next_Consumed; while (true) { while (in == out) ; /* 아무 일도 안 함 */ next_Consumed = buffer[out]; out = (out + 1) % BUFFER_SIZE; /* next_Consumed에 있는 item을 소비 */ }

// 메시지 전달을 사용하는 생산자 프로세스 message next produced; while(true) { /* next_produced에 생산된 item 저장 */ send(ext produced); }

// 메시지 전달을 사용하는 소비자 프로세스 message next consumed; while (true) { receive(next consumed); /* next_consumed에 있는 item 소비 */ }

// Date 서버 import java.net.*; import java.io.*; public class DateServer { public static void main(String[] args) { try { ServerSocket sock = new ServerSocket(6013); // 연결을 listen() 한다 while (true) { Socket client = sock.accept(); PrintWriter pout = new PrintWriter(client.getOutputStream(), true); // Date를 소켓에 쓴다. pout.println(new java.util.Date().toString()); // 소켓을 닫고 다시 시작한다. client.close(); } } catch (IOException ioe) { System.err.println(ioe); } } }

// Date 클라이언트 import java.net.*; import java.io.*; public class DateClient { public static void main(String[] args) { try { // 서버 소켓과의 연결을 만든다. Socket sock = new Socket("127.0.0.1", 6013); InputStream in = sock.getInputStream(); BufferedReader bin = new BufferedReader(new InputStreamReader(in)); // 소켓으로부터 날짜를 읽는다. String line; while ( (line = bine.readLine()) != null) System.out.println(line); // 소켓 연결을 닫는다. } catch (IOException ioe) { System.err.println(ioe); } } }

pipe(inf fd[]);

#include <sys/types.h> #include <stdio.h> #include <string.h> #include <unistd.h> #define BUFFER_SIZE 25 #define READ_END 0 #define WRITE_END 1 int main(void) { char write_msg[BUFFER_SIZE] = "Greetings"; char read_msg[BUFFER_SIZE]; int fd[2]; pid_t pid; /* 파이프 생성 */ if (pipe(fd) == 1) { fprintf(stderr, "Pipe failed"); return 1; } /* 자식 프로세스 생성 */ pid = fork(); if (pid < 0) { fprintf(stderr, "Fork Failed"); return 1; } if (pid > 0 { /* 부모 프로세스 */ /* 파이프의 사용하지 않는 쪽을 닫는다 */ close(fd[READ_END]); /* 파이프에 쓴다 */ write(fd[WRITE_END], write_msg, strlen(write_msg)+1); /* 파이프의 쓰기 쪽을 닫는다 */ close(fd[WRITE_END]); } else { /* 자식 프로세스 */ /* 파이프의 사용하지 않는 쪽을 닫는다 */ close(fd[WRITE_END]); /* 파이프로부터 읽는다 */ read(fd[READ_END], read_msg, BUFFER_SIZE); printf("child read %s\n", read_msg); /* 파이프의 읽기 쪽을 닫는다 */ close(fd[READ_END]); } return 0; }

// Windows 익명 파이프 - 부모 프로세스 #include <stdio.h> #include <stdlib.h> #include <windows.h> #define BUFFER_SIZE 25 int main(VOID) { HANDLE ReadHandle, WriteHandle; STARTUPINFO si; PROCESS_INFORMATION pi; char message[BUFFER_SIZE] = "Greetings"; DWORD written; /* 파이프가 상속받을 보안 속성을 설정한다 */ SECURITY_ATTRIBUTES sa = { sizeof(SECURITY_ATTRIBUTES), NULL, TRUE }; /* 메모리 할당 */ ZeroMemory(&pi, sizeof(pi)); /* 파이프 생성 */ if (!CreatePipe(&ReadHandle, &WriteHandle, &sa, 0)) { fprintf(stderr, "Create Pipe Failed\n"); return 1; } /* 자식 프로세스를 위한 START_INFO 구조를 구축한다 */ GetStartupInfo(&si); si.hStdOutput = GetStdHandle(STD_OUTPUT_HANDLE); /* 표준 입력을 파이프의 읽기 쪽으로 재지정한다 */ si.hStdInput = ReadHandle; si.dwFlags = STARTF_USETDHANDLES; /* 자식 프로세스가 파이프의 쓰기 쪽을 상속 받지 않도록 한다 */ SetHandleInformation(WriteHandle, HANDLE_FLAG_INHERIT, 0); /* 자식 프로세스 생성 */ CreateProcess(NULL, "child.exe", NULL, NULL, TRUE, /* inherit handles */ 0, NULL, NULL, &si, &pi)); /* 파이프의 사용하지 않는 쪽을 닫는다 */ CloseHandle(ReadHandle); /* 부모 프로세스가 파이프에 쓴다 */ if(!WriteFile(WriteHandle, message, BUFFER_SIE &wirtten, NULL)) fprintf(stderr, "Error writing to pipe\n"); /* 파이프의 쓰기 쪽을 닫는다 */ CloseHandle(WriteHandle); /* 자식이 종료하기를 기다린다 */ WaitForSingleObject(pi.hProcess, INFINITE); CloseHandle(pi.hProcess); CloseHandle(pi.hThread); return 0; }

// Windows 익명 파이프 - 자식 프로세스 #include <stdio.h> #include <windows.h> #define BUFFER_SIZE 25 int main(VOID) { HANDLE ReadHandle; CHAR buffer[BUFFER_SIZE]; DWORD read; /* 파이프의 읽기 핸들을 얻는다 */ ReadHandle = GetStdHandle(STD_INPUT_HANDLE); /* 부모 프로세스가 파이프에 쓴다 */ if(ReadFile(ReadHandle, buffer, BUFFER_SIE &read, NULL)) printf("child: >%s<", buffer); else fprintf(stderr, "Child: Error reading from pipe\n"); return 0; }