- 뭐, 미안하다고?
선진국에 가보면, 약간만 부딛힐 듯한 상황이라면, 서로 'Excuse me', '스미마셍'같이 서로를 배려하는 모습을 볼 수 있습니다. 우리나라에서는 아직 길을 걸으면서 뒷 사람에게 담배연기를 선사한다던가, 뭐 그리 급한지 보행자일 때는 운전자를, 운전할 때는 보행자를 씹으면서 급하게 서두르는 모습을 쉽게 볼 수 있습니다. 층간소음이 일어나면 오히려 윗집이 더 큰소리를 치기도 하죠. 시민의식으로 겨루는 한일전에서도 완승을 거뒀으면 좋겠다는 생각을 합니다만, 저 역시 모범시민은 아니기에 같이 노력해야겠죠. 어허허허헣. 오늘은 닷넷이 예절을 얼마나 잘 지키는 지, 한번 살펴보겠습니다.
- Stop it, Now!
위 소제목을 보시고, 잭 바우어를 떠올렸다면, 24시의 팬이시겠군요. 잭 바우어는 너무나도 급한 상황을 많이 만나는데요, 상대방에게는 정말 미안하지만, 상황을 해결하기 위해서 윽박지르고, 때로는 때리고, 아주 때로는 다리를 쏘는 등등등! 의 방법을 사용합니다.
아흙. 닷넷의 멀티 스레드 환경을 한번 생각해보죠. 여러개의 스레드가 작업을 처리하는 동안, 하나의 스레드는 사용자의 UI에서 입력을 기다립니다. 그리고 사용자가 취소버튼을 누르면, 사용자의 의지를 이어받아서 다른 스레드들을 취소해야 하는데요. 기존의 .NET 3.5까지는 작업 중인 스레드를 취소하는 게 매우 무례했습니다. 취소해야 할 때는 기냥 바로 끼어들어서 취소해버렸기 때문이죠. 그렇게 하면, 데이터 업데이트가 이뤄지는 도중에 취소되어서 부분적으로만 데이터가 업데이트 된다든지, 자원해제가 제대로 안 된다든지 하는 부작용의 위험이 항상 존재합니다. 그래서 가능하면, 다른 방법이 전혀 없을 때, 이렇게 하는 것이 좋겠죠?
물론 기존의 방식도 여전히 활용가능하지만, 이젠 닷넷이 많이 예의를 갖췄습니다. 닷넷 4.0에 새롭게 추가된 PLINQ나 TPL을 사용하는 경우에는 취소 요청 접근법(cancellation request approach)만 사용할 수 있는데요, 이런 방식을 협력적인 취소(cooperative cancellation)이라고 합니다. 즉, 한 스레드가 다른 스레드를 강제로 종료시키는 게 아니라, 작업 취소 API를 통해서 작업을 취소해줄 것을 요청하는 것이죠. 취소 플래그를 통해서 취소요청을 받은 작업은 취소요청에 어떻게 응답할 것인지 선택할 수 있습니다. 예제를 하나 보시죠.
|
using System;
using System.Threading.Tasks;
using System.Threading;
namespace Exam11
{
class Program
{
static void PrintDash(CancellationToken cancellationToken)
{
cancellationToken.Register(Canceled);
while (!cancellationToken.IsCancellationRequested)
{
Console.Write("-");
}
}
static void Canceled()
{
Console.WriteLine("작업이 취소되었군요!!");
}
static void Main(string[] args)
{
string stars = "*".PadRight(Console.WindowWidth - 1, '*');
CancellationTokenSource cancellationTokenSource =
new CancellationTokenSource();
Task task = Task.Factory.StartNew(
() => PrintDash(cancellationTokenSource.Token));
Console.ReadLine();
cancellationTokenSource.Cancel();
Console.WriteLine(stars);
task.Wait();
Console.WriteLine("작업의 완료상태 : {0}", task.Status);
Console.WriteLine();
}
}
} |
<코드1> 취소 요청 접근법.
<코드1>은 그냥 평범하게 '-'를 출력하는 예제입니다. 하지만, 새로운 클래스가 몇개 보이는데요. CancellationTokenSource, CancellationToken클래스말이죠.
|
namespace System.Threading
{
[ComVisible(false)]
[DebuggerDisplay("IsCancellationRequested = {IsCancellationRequested}")]
public struct CancellationToken
{
public CancellationToken(bool canceled);
public static bool operator !=(CancellationToken left, CancellationToken right);
public static bool operator ==(CancellationToken left, CancellationToken right);
public bool CanBeCanceled { get; }
public bool IsCancellationRequested { get; }
public static CancellationToken None { get; }
public WaitHandle WaitHandle { get; }
public bool Equals(CancellationToken other);
public override bool Equals(object other);
public override int GetHashCode();
public CancellationTokenRegistration Register(Action callback);
public CancellationTokenRegistration Register(Action<object> callback, object state);
public CancellationTokenRegistration Register(Action callback, bool useSynchronizationContext);
public CancellationTokenRegistration Register(Action<object> callback, object state, bool useSynchronizationContext);
public void ThrowIfCancellationRequested();
}
} |
<코드2> 구조체 CancellationToken.
CancellationToken클래스는 말 그대로, 현재 이 토큰이 어떤 상태에 있는지 모니터링 하기 위한 정보를 갖고 있습니다. 이 토큰이 현재 취소 요청을 받았는지, 취소요청을 받으면 어떤 행동을 취할 것인지 등을 확인하고, 설정할 수 있습니다.
|
namespace System.Threading
{
[ComVisible(false)]
public sealed class CancellationTokenSource : IDisposable
{
public CancellationTokenSource();
public bool IsCancellationRequested { get; }
public CancellationToken Token { get; }
public void Cancel();
public void Cancel(bool throwOnFirstException);
public static CancellationTokenSource CreateLinkedTokenSource(params CancellationToken[] tokens);
public static CancellationTokenSource CreateLinkedTokenSource(CancellationToken token1, CancellationToken token2);
public void Dispose();
}
} |
<코드3> CancellationTokenSource 클래스
그리고 CancellationTokenSource는 CancellationToken의 기반이 되는 클래스로(Source라는 이름이 붙어있죠), CancellationTokenSource에서 생성된 각각의 Token에 대해서 취소를 요청하는 역할을 합니다. CancellationTokenSource에서 Cancel메서드로 취소요청을 하면, 같은CancellationTokenSource에서 생성된 Token들은 전부 취소요청을 받는 셈이죠.
한가지 주목해서 보실 점은 CancellationToken가 클래스가 아니라 구조체라는 것입니다. 즉, Token을 매번 다른 객체에 넘겨줄 때마다 새로운 복사본이 생성된다는 것이죠. 그래서 각각의 스레드에 넘겨진 Token은 각각 독립적인 복사본 이므로, Cancel메서드는 스레드 안전성(thread-safe)을 확보할 수 있습니다. 만약에 참조가 그냥 복사된다면, 각각의 스레드가 Token에 손을 대면, 다른 스레드가 참조하는 Token에도 동일한 변화가 생겨서 예측불가능한 일이 벌어지겠죠.
<코드1>을 보면, 병렬적으로 수행되는 작업에서 취소 요청을 모니터링하기 위해서, CancellationToken을 인자로 넘겨주는 것을 볼 수 있습니다. 그래서 PrintDash메서드 내부에서 IsCancellationRequested속성을 통해서 작업 취소 요청이 들어왔는지 계속 해서 확인하게 되죠. 그럼 <코드1>을 실행 해볼까요?
|
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
--작업이 취소되었군요!!
*******************************************************************************
작업의 완료상태 : RanToCompletion
계속하려면 아무 키나 누르십시오 . . . |
<결과1> <코드1>의 실행결과.
<결과1>을 보면, 작업의 완료상태를 출력하는 부분이 있는데요, 이 부분에서 RanToCompletion이 출력되고 있습니다. 그래서 만약, ContinueWith메서드로 연쇄 작업을 연결하고, 옵션을 OnlyOnCanceled로 설정해준다고 하더라도, 연쇄작업은 실행되지 않습니다. 작업은 완료된 상태이기 때문에, 연쇄 작업이 취소되었다는 에러메세지만 확인할 수 있을 뿐이죠. 그렇다면, 연쇄작업을 이용해서 <코드1>과 동일한 결과를 내려면 어떻게 해야 할까요?
|
using System;
using System.Threading.Tasks;
using System.Threading;
namespace Exam12
{
class Program
{
static void PrintDash(CancellationToken cancellationToken)
{
while (!cancellationToken.IsCancellationRequested)
{
Console.Write("-");
}
if (cancellationToken.IsCancellationRequested)
{
cancellationToken.ThrowIfCancellationRequested();
}
}
static void Main(string[] args)
{
string stars = "*".PadRight(Console.WindowWidth - 1, '*');
CancellationTokenSource cancellationTokenSource =
new CancellationTokenSource();
Task task = Task.Factory.StartNew(
() => PrintDash(cancellationTokenSource.Token),
cancellationTokenSource.Token);
Task canceledTask = task.ContinueWith(
(antecedentTask) => Console.WriteLine("작업이 취소되었군요!!"),
TaskContinuationOptions.OnlyOnCanceled);
Console.ReadLine();
cancellationTokenSource.Cancel();
Console.WriteLine(stars);
canceledTask.Wait();
Console.WriteLine("작업의 완료상태 : {0}", task.Status);
Console.WriteLine();
}
}
} |
<코드4> <코드1>과 동일하지만, 연쇄작업을 사용하는 코드.
<코드4>가 바로, <코드1>과 동일한 결과를 내는 코드입니다.(사실 완전히 같지는 않습니다. 실행해보면, '작업이 취소되었군요!'라는 멘트가 출력되는 위치가 다르지요.) 이런식으로 연쇄작업을 연결해놓고, 병렬로 실행되는 메서드 안에서, ThrowIfCancellationRequested()메서드를 통해서, 취소되었을 때, 취소되었다는 표시를 하도록 한 것이죠. 그러면, 연쇄 작업이 바톤을 이어받아서 실행을 계속하게 됩니다. 그리고 또 한가지 차이점은 작업을 생성할 때, 인자로 Token을 넘겨준다는 것이지요.
- 마치면서.
요즘 월드컵을 보면 16강이 가능할 것 같다는 생각이 들기도 하는데요. 꼭! 갔으면 좋겠네요!! ......이게 마무리 멘트라니-_-!! 어헣.
- 참고자료
1. Essential C# 4.0, Mark Michaelis, Addison Wesley
OpenInBlendRegHack.zip
