StackExchange.Redis
Profilowy
Szukaj…
Uwagi
Funkcje profilowania StackExchange.Redis składają się z interfejsu IProfiler oraz ConnectionMultiplexer.RegisterProfiler(IProfiler) , ConnectionMultiplexer.BeginProfiling(object) , ConnectionMultiplexer.FinishProfiling(object) .
Profilowanie Rozpocznij i Zakończ pobiera object kontekstowy, dzięki czemu powiązane polecenia mogą być grupowane razem.
To grupowanie polega na IProfiler zapytania do interfejsu IProfiler o obiekt kontekstowy na początku polecenia przed wystąpieniem jakichkolwiek wątków shenanigans i powiązaniu tego polecenia z dowolnymi innymi poleceniami, które mają ten sam obiekt kontekstowy. Początek musi zostać wywołany z tym samym obiektem kontekstowym, aby StackExchange.Redis wiedział, że można rozpocząć polecenia profilowania z tym obiektem kontekstowym, a Finish jest wywoływany, aby zatrzymać profilowanie i zwrócić wyniki.
Zgrupuj wszystkie polecenia z zestawu wątków razem
class ToyProfiler : IProfiler
{
public ConcurrentDictionary<Thread, object> Contexts = new ConcurrentDictionary<Thread, object>();
public object GetContext()
{
object ctx;
if(!Contexts.TryGetValue(Thread.CurrentThread, out ctx)) ctx = null;
return ctx;
}
}
// ...
ConnectionMultiplexer conn = /* initialization */;
var profiler = new ToyProfiler();
var thisGroupContext = new object();
conn.RegisterProfiler(profiler);
var threads = new List<Thread>();
for (var i = 0; i < 16; i++)
{
var db = conn.GetDatabase(i);
var thread =
new Thread(
delegate()
{
var threadTasks = new List<Task>();
for (var j = 0; j < 1000; j++)
{
var task = db.StringSetAsync("" + j, "" + j);
threadTasks.Add(task);
}
Task.WaitAll(threadTasks.ToArray());
}
);
profiler.Contexts[thread] = thisGroupContext;
threads.Add(thread);
}
conn.BeginProfiling(thisGroupContext);
threads.ForEach(thread => thread.Start());
threads.ForEach(thread => thread.Join());
IEnumerable<IProfiledCommand> timings = conn.FinishProfiling(thisGroupContext);
Na koniec czasy będą zawierać 16 000 obiektów IProfiledCommand - po jednym dla każdego polecenia wydanego do redis.
Komendy grupowe na podstawie wydawanego wątku
ConnectionMultiplexer conn = /* initialization */;
var profiler = new ToyProfiler();
conn.RegisterProfiler(profiler);
var threads = new List<Thread>();
var perThreadTimings = new ConcurrentDictionary<Thread, List<IProfiledCommand>>();
for (var i = 0; i < 16; i++)
{
var db = conn.GetDatabase(i);
var thread =
new Thread(
delegate()
{
var threadTasks = new List<Task>();
conn.BeginProfiling(Thread.CurrentThread);
for (var j = 0; j < 1000; j++)
{
var task = db.StringSetAsync("" + j, "" + j);
threadTasks.Add(task);
}
Task.WaitAll(threadTasks.ToArray());
perThreadTimings[Thread.CurrentThread] = conn.FinishProfiling(Thread.CurrentThread).ToList();
}
);
profiler.Contexts[thread] = thread;
threads.Add(thread);
}
threads.ForEach(thread => thread.Start());
threads.ForEach(thread => thread.Join());
perThreadTimings kończy się 16 wpisami 1000 IProfilingCommands, wpisanymi przez Wątek, który je wydał.