c# 4.0에서 멀티스레드 구현할 때 썼던 것

소스

public class ThreadWorker : IDisposable
{
    Thread th;
    public event EventHandler DoWork;
    public event EventHandler OnCompleted;
    public string Name;
    public event ProcessChangedEventHandler OnProcessChanged;
    public delegate void ProcessChangedEventHandler(object sender, ProgressEventArgs e);

    // 기타 전달할 데이터
    public object Props;

    public ThreadWorker()
    {
        th = new Thread(Work);
        th.IsBackground = true;
    }

    public ThreadState Status()
    {
        return th.ThreadState;
    }

    public void Stop()
    {
        th.Abort();
    }

    public void ReportProgress(float per)
    {
        OnProcessChanged?.Invoke(this, new ProgressEventArgs(per));
    }

    public void Run(bool isJoin = false)
    {
        th.Start();
        if (isJoin)
            th.Join();
    }

    private void Work()
    {
        DoWork?.Invoke(this, EventArgs.Empty);
        OnCompleted?.Invoke(this, EventArgs.Empty);
    }

    public void Dispose()
    {
        GC.SuppressFinalize(this);
    }
}

public class ProgressEventArgs : EventArgs
{
    public ProgressEventArgs(float percent)
    {
        this.Percent = percent;
    }

    public float Percent { get; private set; }
}

사용법(예시)

public partial class Form1 : Form
{
    public Form1()
    {
        InitializeComponent();
    }
    // 쓰레드 세이프티 한 조건을 만족하기 위해서 lock을 걸기위해 사용
    private object lockObject = new object();

    // 모든 쓰레드를 중지할 때 각각의 작업들 앞에서 IsRunning을 조회하여 중지시키도록 한다
    private static bool IsRunning = false;

    // 쓰레드 들을 관리할 수 있는 리스트
    private static List<ThreadWorker> jobList = new List<ThreadWorker>();

    // progress용 최대치(전체 작업개수)
    private static int totalJobCount = 0;
    // 현재 완료된 작업 갯수
    private static int curCount = 0;

    Stopwatch stopwatch = new Stopwatch();

    private void SetProgress()
    {
        this.Invoke(new MethodInvoker(delegate
        {
            Monitor.Enter(lockObject);
            curCount++;
            this.progressBar.Value = curCount;
            Application.DoEvents();
            Monitor.Exit(lockObject);
        }));
    }

    private void Tw_OnCompleted(object sender, EventArgs e)
    {
        if (!IsRunning)
            return;

        // 쓰레드가 완료될 때마다 사용한 쓰레드 삭제
        ThreadWorker tw = ((ThreadWorker)sender);
        tw.Dispose();

        Monitor.Enter(lockObject);
        // 모든 스레드가 동일 배열을 바라보고 있어서 lock을 걸어주었다.
        jobList.Remove(tw);
        Monitor.Exit(lockObject);

        if (jobList.Count() == 0)
        {
            this.Invoke(new MethodInvoker(delegate
            {
                setEnableControl(false);

                stopwatch.Stop();
                log(string.Format("Time elapsed: {0}", stopwatch.Elapsed));

                // 완료시 진행할 내역들

            }));

        }
    }

    private void log(string msg)
    {
        this.textBox1.Invoke((MethodInvoker)(() => {
            this.textBox1.AppendText(msg);
            this.textBox1.AppendText(Environment.NewLine);
            Application.DoEvents();
        }));
    }

    private void Tw_DoWork(object sender, EventArgs e)
    {
        (T) props = ((ThreadWorker)sender).Props;

        for (int i = 0; i < 20; i++)
        {
            if (!IsRunning)
                break;

            // 작업할 내용 작성

            SetProgress();
        }
    }

    private void testStart()
    {
        for (int i = 0; i < 10; i++)
        {
            if (!IsRunning)
                break;
            // 쓰레드 생성하면서 작업 시작
            ThreadWorker tw = new ThreadWorker();
            tw.DoWork += Tw_DoWork;
            tw.OnCompleted += Tw_OnCompleted;
            tw.Props = // 작업에 필요한 추가 데이터;
            tw.Run();
            jobList.Add(tw);
        }

    }

    private void Form1_Load(object sender, EventArgs e)
    {
        btnStop.Enable(false);
    }

    private void btnStart_Click(object sender, EventArgs e)
    {
        setEnableControl(true);
        IsRunning = true;
        this.progressBar.Value = curCount = 0;
        this.textBox1.Clear();
        stopwatch.Restart();
        Application.DoEvents();

        // 이제부터 호출 테스트 시작
        testStart();

    }

    private void setEnableControl(bool isStart)
    {
        if (isStart) {
            this.Enable(false);
            btnStop.Enable(true);
        }
        else
        {
            this.Enable(true);
            btnStop.Enable(false);
        }
        Application.DoEvents();
    }

    private void btnStop_Click(object sender, EventArgs e)
    {
        IsRunning = false;
        Monitor.Enter(lockObject);
        jobList.ForEach(w => {
            w.Dispose();
        });
        jobList.Clear();
        Monitor.Exit(lockObject);

        log("작업 취소됨");

        setEnableControl(false);
    }
}

멀티스레드 작업 완료 이벤트 스레드 콜백 MultiThread Callback Event #2