namespace Microshaoft
{
using System;
using System.Timers;
public class EasyTimer
{
private Timer _timer;
public void Start()
{
if (_timer != null)
{
_timer.Start();
}
}
private int _intervalSeconds;
public EasyTimer
(
int intervalSeconds
, int times
, Action timerAction
, Action<Exception> exceptionAction
)
{
if (timerAction == null)
{
return;
}
_intervalSeconds = intervalSeconds * 1000;
_timer = new Timer(1);
_timer.Elapsed += new ElapsedEventHandler
(
(x, y) =>
{
TimerActionProcess(times, timerAction, exceptionAction);
}
);
}
private void TimerActionProcess(int times, Action timerAction, Action<Exception> exceptionAction)
{
if (_timer.Interval < _intervalSeconds)
{
_timer.Interval = _intervalSeconds;
}
if (timerAction == null)
{
return;
}
_timer.Enabled = false;
_timer.Stop();
DateTime begin;
do
{
begin = DateTime.Now;
try
{
timerAction();
}
catch (Exception e)
{
if (exceptionAction != null)
{
exceptionAction(e);
}
}
} while (Math.Abs(DateTimeHelper.SecondsDiffNow(begin)) > times * _intervalSeconds);
_timer.Start();
_timer.Enabled = true;
}
}
}
namespace Microshaoft
{
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using System.IO;
class Program
{
static void Main()
{
string r = string.Empty;
string rootPath = @"e:\temp4";
Console.WriteLine("测试项目1");
Console.WriteLine("按任意键测试该项目, 按\"q\"退出该测试项目");
while ((r = Console.ReadLine()) != "q")
{
DateTime now = new DateTime(2012, 5, 12);
CodeTimer.Time
(
"写文件"
, 1
, () =>
{
Parallel.For
(
0
, 86400
, (x) =>
{
DateTimeHelper.GetAlignSecondsDateTimes<string>
(
now.AddSeconds(x)
, Tuple.Create<long, Func<DateTime, long, DateTime, string, string>>
(
24 * 60 * 60
, (time, alignSeconds, alignedTime, data) =>
{
//Console.WriteLine(alignedTime);
var directory = alignedTime.ToString("yyyy-MM-dd");
var path = (string.IsNullOrEmpty(data) || string.IsNullOrWhiteSpace(data) ? rootPath : data);
path = string.Format
(
"{1}{0}{2}"
, @"\"
, path.Trim(new char[] { '\\' })
, directory
);
if (!Directory.Exists(path))
{
Directory.CreateDirectory(path);
}
return path;
}
)
, Tuple.Create<long, Func<DateTime, long, DateTime, string, string>>
(
1 * 60 * 60
, (time, alignSeconds, alignedTime, data) =>
{
//Console.WriteLine(alignedTime);
var directory = alignedTime.ToString("yyyy-MM-dd_HH");
var path = (string.IsNullOrEmpty(data) || string.IsNullOrWhiteSpace(data) ? rootPath : data);
path = string.Format
(
"{1}{0}{2}"
, @"\"
, path.Trim(new char[] { '\\' })
, directory
);
if (!Directory.Exists(path))
{
Directory.CreateDirectory(path);
}
return path;
}
)
, Tuple.Create<long, Func<DateTime, long, DateTime, string, string>>
(
5 * 60
, (time, alignSeconds, alignedTime, data) =>
{
var directory = DateTimeHelper.GetDateTimeString(alignedTime, "yyyy-MM-dd_HH-mm");
var path = (string.IsNullOrEmpty(data) || string.IsNullOrWhiteSpace(data) ? rootPath : data);
path = string.Format
(
"{1}{0}{2}"
, @"\"
, path.Trim(new char[] { '\\' })
, directory
);
if (!Directory.Exists(path))
{
Directory.CreateDirectory(path);
}
if (x % 300 != 0)
{
return string.Empty;
}
string file = string.Empty;
string s = DateTimeHelper.GetDateTimeString(alignedTime, "yyyyMMdd-HHmmss");
file = string.Format
(
"{1}{0}{2}.{3}.txt"
, @"\"
, path
, s
, Guid.NewGuid().ToString("N")
);
using (StreamWriter sw = new StreamWriter(File.OpenWrite(file)))
{
sw.WriteLine(s);
}
return string.Empty;
}
)
);
}
);
}
);
Console.WriteLine("ok");
}
Console.WriteLine("测试项目2");
Console.WriteLine("按任意键测试该项目, 按\"q\"退出该测试项目");
r = string.Empty;
while ((r = Console.ReadLine()) != "q")
{
CodeTimer.ParallelTime
(
"GetFiles"
, 5
, Environment.ProcessorCount
, () =>
{
//Console.WriteLine(Directory.GetDirectories(@"e:\temp2", "*.*", SearchOption.AllDirectories).Length);
string[] files = Directory.GetFiles(rootPath, "*.*", SearchOption.AllDirectories);
var list = files.ToList();
Parallel.ForEach
(
list
, new ParallelOptions()
{
MaxDegreeOfParallelism =
// 1
Environment.ProcessorCount - 0
}
, (x) =>
{
string s = File.ReadAllText(x);
}
);
}
);
}
Console.ReadLine();
}
}
}
namespace Microshaoft
{
using System;
using System.Diagnostics;
using System.Threading;
using System.Threading.Tasks;
using System.Runtime.InteropServices;
public static class CodeTimer
{
public static void Initialize()
{
Process.GetCurrentProcess().PriorityClass = ProcessPriorityClass.High;
Thread.CurrentThread.Priority = ThreadPriority.Highest;
Time("", 1, () => { });
}
public static void ParallelTime(string name, int iteration, int maxDegreeOfParallelism, Action action)
{
InternalIterationProcess
(
name
, iteration
, () =>
{
Parallel.For
(
0
, iteration
, new ParallelOptions()
{
MaxDegreeOfParallelism = maxDegreeOfParallelism
//, TaskScheduler = null
}
, i =>
{
action();
}
);
}
);
}
private static void InternalIterationProcess(string name, int iteration, Action action)
{
if (string.IsNullOrEmpty(name))
{
return;
}
// 1.
ConsoleColor currentForeColor = Console.ForegroundColor;
Console.ForegroundColor = ConsoleColor.Yellow;
Console.WriteLine(name);
// 2.
GC.Collect(GC.MaxGeneration, GCCollectionMode.Forced);
int[] gcCounts = new int[GC.MaxGeneration + 1];
for (int i = 0; i <= GC.MaxGeneration; i++)
{
gcCounts[i] = GC.CollectionCount(i);
}
// 3.
Stopwatch watch = new Stopwatch();
watch.Start();
ulong cycleCount = GetCycleCount();
action();
ulong cpuCycles = GetCycleCount() - cycleCount;
watch.Stop();
// 4.
Console.ForegroundColor = currentForeColor;
Console.WriteLine
(
"{0}Time Elapsed:{0}{1}ms"
, "\t"
, watch.ElapsedMilliseconds.ToString("N0")
);
Console.WriteLine
(
"{0}CPU Cycles:{0}{1}"
, "\t"
, cpuCycles.ToString("N0")
);
// 5.
for (int i = 0; i <= GC.MaxGeneration; i++)
{
int count = GC.CollectionCount(i) - gcCounts[i];
Console.WriteLine
(
"{0}Gen{1}:{0}{0}{2}"
, "\t"
, i
, count
);
}
Console.WriteLine();
}
public static void Time(string name, int iteration, Action action)
{
InternalIterationProcess
(
name
, iteration
, () =>
{
for (int i = 0; i < iteration; i++)
{
action();
}
}
);
}
private static ulong GetCycleCount()
{
ulong cycleCount = 0;
QueryThreadCycleTime(GetCurrentThread(), ref cycleCount);
return cycleCount;
}
[DllImport("kernel32.dll")]
[return: MarshalAs(UnmanagedType.Bool)]
static extern bool QueryThreadCycleTime(IntPtr threadHandle, ref ulong cycleTime);
[DllImport("kernel32.dll")]
static extern IntPtr GetCurrentThread();
}
}
namespace Microshaoft
{
using System;
using System.IO;
using System.Globalization;
public static class DateTimeHelper
{
public static void GetAlignSecondsDateTimes<T>
(
DateTime time
, params Tuple<long, Func<DateTime, long, DateTime, T, T>>[] processAlignSecondsDateTimesFuncs
)
{
T r = default(T);
foreach (var x in processAlignSecondsDateTimesFuncs)
{
var alignSeconds = x.Item1;
var alignTime = DateTimeHelper.GetAlignSecondsDateTime(time, alignSeconds);
if (x.Item2 != null)
{
r = x.Item2(time, alignSeconds, alignTime, r);
}
}
}
public static bool IsVaildateTimestamp(DateTime timeStamp, int timeoutSeconds)
{
long l = SecondsDiffNow(timeStamp);
return ((l > 0) && (l < timeoutSeconds));
}
public static long MillisecondsDiffNow(DateTime time)
{
long now = DateTime.Now.Ticks;
long t = time.Ticks;
return (t - now) / 10000;
}
public static long SecondsDiffNow(DateTime time)
{
return MillisecondsDiffNow(time) / 1000;
}
public static DateTime GetAlignSecondsDateTime(DateTime time, long alignSeconds)
{
long ticks = time.Ticks;
ticks -= ticks % (10000 * 1000 * alignSeconds);
DateTime dt = new DateTime(ticks);
return dt;
}
public static string GetDateTimeString(DateTime time, string format)
{
return time.ToString(format);
}
public static DateTime? ParseExactDateTimeNullable(string text, string format)
{
DateTime time;
DateTime? r = DateTime.TryParseExact
(
text
, format
, DateTimeFormatInfo.InvariantInfo
, DateTimeStyles.None
, out time
) ? time as DateTime? : null;
return r;
}
}
}
|