Synchronize access to stream data section by section

using System;
using System.Collections;
using System.Threading;
using System.IO;


	/// <summary>
	/// Summary description for Class1.
	/// </summary>
	class Class1
	{
		static Byte[] bytes = new Byte[30];
		static ByteStream stream = new ByteStream(new Byte[30]);
		static FileStream file = new FileStream("StreamTest.txt", FileMode.Open, FileAccess.ReadWrite, FileShare.None);
		static MemoryMappedFile memFile = new MemoryMappedFile(file);

		/*
		static void ThreadProc1() {
			Console.Out.WriteLine("Entering thread {0}", Thread.CurrentThread.GetHashCode());
			SectionLock section = new SectionLock(bytes, 0, 14);
			using(section) {
				lock(section.SyncRoot) {
					Console.Out.WriteLine("Stream locked in thread {0}", Thread.CurrentThread.GetHashCode());
					for(int i=0; i<=14; i++) { 
						bytes[i] = 1;
						Thread.Sleep(10); // yield the thread
					}
				}
			}
		}

		static void ThreadProc2() {
			Console.Out.WriteLine("Entering thread {0}", Thread.CurrentThread.GetHashCode());
			SectionLock section = new SectionLock(bytes, 10, 24);
			using(section) {
				lock(section.SyncRoot) {
					Console.Out.WriteLine("Stream locked in thread {0}", Thread.CurrentThread.GetHashCode());
					for(int i=10; i<=24; i++) { 
						bytes[i] = 2;
						Thread.Sleep(10); // yield the thread
					}
				}
			}
		}
		static void ThreadProc3() {
			Console.Out.WriteLine("Entering thread {0}", Thread.CurrentThread.GetHashCode());
			SectionLock section = new SectionLock(bytes, 15, 29);
			using(section) {
				lock(section.SyncRoot) {
					Console.Out.WriteLine("Stream locked in thread {0}", Thread.CurrentThread.GetHashCode());
					for(int i=15; i<=29; i++) { 
						bytes[i] = 3;
						Thread.Sleep(10); // yield the thread
					}
				}
			}
		}
		*/

		/*
		static void ThreadProc1() {
			Console.Out.WriteLine("Entering thread {0}", Thread.CurrentThread.GetHashCode());
			Byte[] bytes = new Byte[15];
			for(int i=0; i<bytes.Length; i++)
				bytes[i] = 1;

			stream.Write(0, bytes, 0, bytes.Length);
		}
		static void ThreadProc2() {
			Console.Out.WriteLine("Entering thread {0}", Thread.CurrentThread.GetHashCode());
			Byte[] bytes = new Byte[15];
			for(int i=0; i<bytes.Length; i++)
				bytes[i] = 2;

			stream.Write(10, bytes, 0, bytes.Length);
		}
		static void ThreadProc3() {
			Console.Out.WriteLine("Entering thread {0}", Thread.CurrentThread.GetHashCode());
			Byte[] bytes = new Byte[15];
			for(int i=0; i<bytes.Length; i++)
				bytes[i] = 3;

			stream.Write(15, bytes, 0, bytes.Length);
		}
		*/

		static void ThreadProc1() {
			Console.Out.WriteLine("Entering thread {0}", Thread.CurrentThread.GetHashCode());
			Byte[] bytes = new Byte[15];
			for(int i=0; i<bytes.Length; i++)
				bytes[i] = 0x31;

			memFile.Write(0, bytes, 0, bytes.Length);
		}
		static void ThreadProc2() {
			Console.Out.WriteLine("Entering thread {0}", Thread.CurrentThread.GetHashCode());
			Byte[] bytes = new Byte[15];
			for(int i=0; i<bytes.Length; i++)
				bytes[i] = 0x32;

			memFile.Write(10, bytes, 0, bytes.Length);
		}
		static void ThreadProc3() {
			Console.Out.WriteLine("Entering thread {0}", Thread.CurrentThread.GetHashCode());
			Byte[] bytes = new Byte[15];
			for(int i=0; i<bytes.Length; i++)
				bytes[i] = 0x33;

			memFile.Write(30, bytes, 0, bytes.Length);
		}

		/// <summary>
		/// The main entry point for the application.
		/// </summary>
		[STAThread]
		static void Main(string[] args)
		{
			Thread thread1 = new Thread(new ThreadStart(ThreadProc1));
			Thread thread2 = new Thread(new ThreadStart(ThreadProc2));
			Thread thread3 = new Thread(new ThreadStart(ThreadProc3));

			thread1.Start();
			thread2.Start();
			thread3.Start();

			thread1.Join();
			thread2.Join();
			thread3.Join();

			bytes = stream.Buffer;
			for(int i=0; i<bytes.Length; i++) 
				Console.Out.WriteLine("{0} : {1}", i, bytes[i] );

			memFile.Dispose();
			file.Close();
		}
	}