Doridori C# 강의 3) 60. 분산처리 프로그램 (Parallel)

======================================================

안녕하세요 Doridori 입니다.

타지에 출장가있는 시기가 길다보니 혼자 생각도 많아지고 이 시간 들을 활용 하고 싶은데 활용은 어렵고, 고민이 많이 되는 시기 인듯 합니다. 

이제 앞으로 조금이면 일단은 서울로 복귀를 하고 이후에 다시 일정이 나올것 같기는 한데 이럴때가 가장 어수선한 시기가 아닌가 싶기도 하네요.

블로그를 보시면 알겠지만 요근래 시간이 나면 여행도 많이 다니면서 기분전환도 많이한것 같고, 개인적으로 해보고 싶은것들도 준비하고 하면서 지내고 있습니다. 

c# 강좌 말고도 이것저것 하고 있으니 보시다가 머리를 식히시고 싶으시면 여행 리뷰나 술 리뷰 보시면서 머리 식히시고 가셔도 좋을 듯 합니다. ^^v

뭔가 성격상 해보고 싶은건 해봐야 멈출 수 있기 때문에 또 하고 싶은걸 해보도록 하겠습니다. ㅎㅎ

모두 화이팅 하십시오!!

(영상에서 parallel 사용 시 작업 순서가 명확할 때에는 사용하면 안된다고 적어 놓은 부분이 잘못 적었다고 수정해야 한다고 했는데, 이게 잘못된 말이 아니고 작업 순서가 명확해야 할 경우에는 분산처리를 사용하지 않는것이 좋습니다.)

======================================================

 

60. 분산처리 프로그램 (Parallel)

UI)

60. 분산처리 프로그램 (Parallel) (UI).zip

0.77MB

Soruce)

60. 분산처리 프로그램 (Parallel).zip

0.77MB

 

 

교재)

60. 분산처리 프로그램 (Parallel).pdf

0.21MB

 

 

지난번 성능 카운터를 이야기 하면서 이번 강의와 엮어서 준비를 하고 있었는데, 진행을 하다 보니 엮기가 쉽지 않아서 시간만 끌릴것 같아 그냥 따로 준비 해보았습니다. 

parallel.for가 처음 나왔을 때 신기술은 바로 사용해야 찐개발이지 라고 하고 사용 했다가 프로그램이 down되서 바로 일반 for문으로 돌렸던 기억이 있어서 조심스러운 느낌이기도 했습니다. 

분명히 좋은 기능이지만 잘생각해보고 사용해야 하는것이 아닌가 라는 생각이 많이 드는 기술(?) 이네요 ㅎ

UI)

살짝 급하게 만들다 보니 이것저것 더 넣고 싶었던게 많은데 그래도 나름 나쁘지 않은(?), 하고 싶은 이야기를 충분히 담은 예제를 만들 수 있었던것 같습니다. 

진행하면서 예전에 action이나 list 초기화 하는 부분이나 이런 부분들도 한번 다시 짚어 봤으니 나름 재미있게 보실 수 있지 않을까 생각 합니다. 

강의)

뭔가 되게 텐션이 높은 상태에서 강의를 준비한것이 아니라 약간 차분한 느낌으로 강의를 만들었던것 같은데 살짝 아쉽긴 하지만 예제를 만들고 바로 강의를 찍어서 내용의 흐름 자체는 만족하면서 진행 했던것 같습니다. 

강의 중간에 사용시 주의점을 잘못 말씀 드린 부분이 있긴 한데 (작업 순서를 보장하지 않기 때문에 작업순서가 명확해야 할 경우에는 사용을 지양하는것이 좋습니다.) 

나름 재미 있는 기능이 아닐까 싶기는 하네요. ㅎ 

 

Source)

소스를 올리는 부분이 상당히 귀찮기는 한데 이 부분의 경우 다른 분들보다도 구독하시는 분들이 질문을 올려주시면 제가 내용을 확인하는 용도로 많이 사용하기 때문에 안올릴수도 없고 ㅎㅎ 

그러다보니 강의용 프로그램을 짤때에는 클래스를 안쪼개는게 습관이 되고 있네요. (별로 좋은것 같지는 않지만. ㅎㅎ;;)

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
 
namespace pCounter
{
    public partial class Form1 : Form
    {
 
        #region Enum
        // Case문 관련 enum
        enum enCase
        {
            nfor,  
            pfor,
            pforeach,
            pfunction,
        }
        #endregion
 
 
 
        #region 
        private int _iThreadSleepTime = 10;  // Thread Sleep
        
        private int _iforStart = 0;   // for Start
        private int _iforCount = 100;  // for Count
 
        DateTime sTime;  // Thread 시작 시간을 가져오기 위함 Function
        #endregion
 
 
 
        public Form1()
        {
            InitializeComponent();
        }
 
 
 
        #region Event 
 
        // 일반 For 문
        private void btnfor_Click(object sender, EventArgs e)
        {
            pThread(enCase.nfor);
        }
 
 
        // Parallel For 문
        private void btnPararallfor_Click(object sender, EventArgs e)
        {
            pThread(enCase.pfor);  // UI에서 바로 작업 할 경우 Event와 Parallel문의 경우 충돌이 발생 할 확률이 크기 때문에 별도 Thread를 구성해서 동작 하도록 함
        }
 
 
        // Parallel Foreach 문
        private void btnParallelforeach_Click(object sender, EventArgs e)
        {
            pThread(enCase.pforeach);
        }
 
 
        // Parallel function
        private void btnParallelFunction_Click(object sender, EventArgs e)
        {
            pThread(enCase.pfunction);
        }
 
        #endregion
 
 
 
        #region Main Thread 
 
        private void pThread(enCase eCase)
        {
            sTime = DateTime.Now;
            Log(lboxPlayTime, enLogLevel.Info, $"Thread Start");
 
            Thread tCase;
 
            switch (eCase)
            {
                case enCase.nfor:
                    tCase = new Thread(fnfor);
                    tCase.Start();
                    break;
                case enCase.pfor:
                    tCase = new Thread(fpfor);
                    tCase.Start();
                    break;
                case enCase.pforeach:
                    tCase = new Thread(fpforeach);
                    tCase.Start();
                    break;
                case enCase.pfunction:
                    tCase = new Thread(fpfunction);
                    tCase.Start();
                    break;
                default:
                    break;
            }
        }
 
        #endregion
 
 
 
        #region innerfunction
 
        // 일반 for 문
        private void fnfor()
        {
            for (int i = _iforStart; i < _iforCount; i++)
            {
                Log(enLogLevel.Info, $"for : {i}");
                Thread.Sleep(_iThreadSleepTime);
            }
 
            DateTime eTime = DateTime.Now;
            Log(lboxPlayTime, enLogLevel.Info, $"Thread End : {eTime - sTime}");
        }
 
 
        // Parallel for 문 (여러 형태로 사용 가능)
        private void fpfor()
        {
            int iTotal = 0;
 
            // 람다식
            Parallel.For(_iforStart, _iforCount, i =>
            {
                //Log(enLogLevel.Info, $"pfor(람다) : {iTotal} + {i} = {iTotal = iTotal + i}");  // 순서를 보장하지 않음
                Log(enLogLevel.Info, $"pfor(람다) : {i}");
                Thread.Sleep(_iThreadSleepTime);
            });
 
            DateTime eTime = DateTime.Now;
            Log(lboxPlayTime, enLogLevel.Info, $"Thread End : {eTime - sTime}");
 
            //Parallel.For(_iforStart, _iforCount, pfun);
 
 
            // 무명메서드
            /*
            Parallel.For(_iforStart, _iforCount, delegate(int i)
            {
                Log(enLogLevel.Info, $"pfor(무명) : {i}");
                Thread.Sleep(10);
            });
            */
 
            /*
            // 람다식
            Parallel.For(_iforStart, _iforCount, (i) =>
            {
                Log(enLogLevel.Info, $"pfor(람다) : {i}");
                Thread.Sleep(10);
            });
            */
        }
 
        /*
        Action<int> afun = pfun;
 
        public static void pfun(int a)
        {
            
        }
        */
 
 
        // Parallel foreach 문 (배열 선언 후 사용)
        private void fpforeach()
        {
            //List<int> iList = (Enumerable.Repeat(i++, 10)).ToList<int>();   // 선언 하면서 같은 수로 초기화 하는 법
            List<int> iList = (Enumerable.Range(_iforStart, _iforCount)).ToList<int>();   // 선언 하면서 순차적으로 값을 넣는 법
 
            Parallel.ForEach(iList, i =>
            {
                Log(enLogLevel.Info, $"pforeach(람다) : {i}");
                Thread.Sleep(_iThreadSleepTime);
            });
 
            DateTime eTime = DateTime.Now;
 
            Log(lboxPlayTime, enLogLevel.Info, $"Thread End : {eTime - sTime}");
        }
 
 
        // parallel function (다중 함수 호출)
        private void fpfunction()
        {
            Parallel.Invoke(
                fpfor,
                fpforeach
            );
 
            /*
            Parallel.Invoke(
                () => { return; },
                () => { return; },
                () => { return; }
            );
            */
        }
 
        #endregion
 
 
 
        #region Log Viewer 
 
        // Log Level을 지정 할 Enum (44강 Tree View 참조)
        enum enLogLevel
        {
            Info,
            Warning,
            Error,
        }
 
        private void Log(enLogLevel eLevel, string LogDesc)
        {
            this.Invoke(new Action(delegate ()
            {
                DateTime dTime = DateTime.Now;
                string LogInfo = $"{dTime:yyyy-MM-dd hh:mm:ss.fff} [{eLevel.ToString()}] {LogDesc}";
                lboxLog.Items.Insert(0, LogInfo);
                Refresh();
            }));
        }
 
        private void Log(DateTime dTime, enLogLevel eLevel, string LogDesc)
        {
            this.Invoke(new Action(delegate ()
            {
                string LogInfo = $"{dTime:yyyy-MM-dd hh:mm:ss.fff} [{eLevel.ToString()}] {LogDesc}";
                lboxLog.Items.Insert(0, LogInfo);
            }));
        }
 
        // List Box Control 추가
        private void Log(ListBox lbox, enLogLevel eLevel, string LogDesc)
        {
            this.Invoke(new Action(delegate ()
            {
                DateTime dTime = DateTime.Now;
                string LogInfo = $"{dTime:yyyy-MM-dd hh:mm:ss.fff} [{eLevel.ToString()}] {LogDesc}";
                lbox.Items.Insert(0, LogInfo);
            }));
        }
 
        #endregion
 
    }
}