using System.Diagnostics;

namespace System.Threading.Tasks
{
	[DebuggerDisplay("ShouldExitCurrentIteration = {ShouldExitCurrentIteration}")]
	public class ParallelLoopState
	{
		internal class ExternalInfos
		{
			public bool IsStopped;

			public AtomicBooleanValue IsBroken = default(AtomicBooleanValue);

			public volatile bool IsExceptional;

			public long? LowestBreakIteration;
		}

		private ExternalInfos extInfos;

		public bool IsStopped => extInfos.IsStopped;

		public bool IsExceptional => extInfos.IsExceptional;

		public long? LowestBreakIteration => extInfos.LowestBreakIteration;

		internal int CurrentIteration { get; set; }

		public bool ShouldExitCurrentIteration
		{
			get
			{
				if (!IsExceptional)
				{
					return IsStopped;
				}
				return true;
			}
		}

		internal ParallelLoopState(ExternalInfos extInfos)
		{
			this.extInfos = extInfos;
		}

		public void Break()
		{
			if (extInfos.IsStopped)
			{
				throw new InvalidOperationException("The Stop method was previously called. Break and Stop may not be used in combination by iterations of the same loop.");
			}
			if (!extInfos.IsBroken.Exchange(newVal: true))
			{
				extInfos.LowestBreakIteration = CurrentIteration;
			}
		}

		public void Stop()
		{
			if (extInfos.IsBroken.Value)
			{
				throw new InvalidOperationException("The Break method was previously called. Break and Stop may not be used in combination by iterations of the same loop.");
			}
			extInfos.IsStopped = true;
		}
	}
}