using System;using System.IO;using System.Linq;

using System.Threading;             

using DiskQueue;

​

​

public class Program

{

    public static void Main()

    {

        IPersistentQueue queue = new PersistentQueue("queue_a");

        var t1 = new Thread(() =>

        {

            int i = 0;

            while (i < 10)

            {

                using (var session = queue.OpenSession())

                {

                    byte[] b = BitConverter.GetBytes(i);

                    session.Enqueue(b);

                    session.Flush();

                }

                i++;

            }

        });

        var t2 = new Thread(()=> {

            while (true) {

                using (var session = queue.OpenSession()) {

                    var data = session.Dequeue();

                    if (data == null) {Thread.Sleep(100); continue;}

​

                    try {

                        File.ReadAllLines("queue_a/data.0").ToList().ForEach(x => Console.WriteLine(x));

                        //Console.WriteLine(BitConverter.ToInt32(data, 0));

                        session.Flush();

                    } catch {

                        session.Flush();

                    }

                }

            }

        });

​

        t1.Start();

        t2.Start();

        Console.WriteLine("outside");

        Directory.EnumerateFiles("queue_a").ToList().ForEach(x => Console.WriteLine(x));

        File.ReadAllLines("queue_a/data.0").ToList().ForEach(x => Console.WriteLine(x));

        Console.WriteLine("outside done");

    }

}