CancellableTaskGrain.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Orleans;
using System.Threading;

namespace GrainCollection
{
    public interface ICancellableTask : IGrainWithIntegerKey
    {
        Task ProcessNudgeEvent();
    }

    public class CancellableTaskGrain : Grain, ICancellableTask
    {
        private CancellationTokenSource _cts;

        public Task ProcessNudgeEvent()
        {
            if (_cts != null)
            {
                _cts.Cancel();
                _cts.Dispose();
            }

            _cts = new CancellationTokenSource();
            return Task.Factory.StartNew(() =>
            {
                // invoke some long running method
            }, _cts.Token);
        }
    }
}