6번째 스터디

과제

[구현내용]

1. 입력 Thread 는 작업 순서와 작업 내용을 처리 Thread로 전달하고 처리 Thread는 작업 순서를 기준으로 작업 내용을 정리하여 출력

• 조건

  • 입력 Thread

    • 2개 Thread
    • 미리 정의된 파일 을 읽어서 처리 Thread로 전달
    • 파일을 다 읽으면 Thread 종료

  • 처리 Thread

    • 1개 Thread
    • 입력 Thread와 공통적으로 사용할 List 생성
    • 처음 작업이 입력될 때 까지 처리 작업을 진행하지 않음(처음 작업 번호 0)
    • 마지막 작업이 입력되면 Thread 종료 (9번 작업이 입력되면 종료)

구현 코드

using System;
using System.IO;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace ThreadEx
{
    class MainApp
    {
        static List<(string, string)> list = new List<(string, string)>();

        static void Main(string[] args)
        {
            Action<object> readFile = (object obj) =>
            {
                string c = (string)obj;
                StreamReader sr = new StreamReader(new FileStream("c:\\test\\a" + c + ".txt", FileMode.Open));

                while (sr.EndOfStream == false)
                {
                    string str = sr.ReadLine();
                    string[] word = str.Split(',');
                    lock (list)
                    {
                        list.Add((word[0], word[1]));
                    }
                }
                sr.Close();
            };

            Action readList = () =>
            {
                int index = 0;

                while (index < 10)
                {
                    if(list.Count > 0) { 
                        list.Sort();
                        if (index.ToString() == list[0].Item1) {
                            Console.WriteLine($"{list[0].Item1} : {list[0].Item2}");
                            list.RemoveAt(0);
                            index++;
                        }
                    }
                    else
                    {
                        continue;
                    }
                }
            };

            Task t1 = new Task(readFile, "1");

            Task t2 = new Task(readFile, "2");

            Task t3 = new Task(readList);

            t3.Start();
            t1.Start();
            t2.Start();

            t1.Wait();
            t2.Wait();
            t3.Wait();

        }
    }
}

Output

0 : 0번작업
1 : 1번작업
2 : 2번작업
3 : 3번작업
4 : 4번작업
5 : 5번작업
6 : 6번작업
7 : 7번작업
8 : 8번작업
9 : 9번작업

• 위의 코드는 3개의 스레드에 의해 파일을 읽고 내용을 출력한다.
• 스레드의 실행순서는 처리Thread => 입력Thread1 => 입력Thread2 이다.
• 이렇게 실행순서를 정의한 이유는 만일 파일크기가 굉장히 크고 입력 Thread가 먼저 실행된다면 처리 스레드가 켜지면서 처리해야될 리스트의 크기가 굉장히 클 수도 있을 뿐더러 만일 List의 최대 크기를 넘어선다면 프로그램이 비정상적으로 작동할 수 있다. => 이러한 이유로 현재 개발하실 때에도 처리Thread를 먼저 동작시킨 후 입력 Thread를 동작시킨다고 함.
• 추가내용 : 하나의 객체에 할당할 수 있는 최대 크기 => LargeObject를 이용해서 초과할 수 있음

추가내용

• Entity Framework ORM 인스턴스 생성 예제 교육받기로 했음!