|
@@ -17,7 +17,7 @@ namespace Model
|
|
|
/// </summary>
|
|
/// </summary>
|
|
|
public class DBCacheComponent : Component
|
|
public class DBCacheComponent : Component
|
|
|
{
|
|
{
|
|
|
- public Dictionary<string, Dictionary<long, Disposer>> cache = new Dictionary<string, Dictionary<long, Disposer>>();
|
|
|
|
|
|
|
+ public Dictionary<string, Dictionary<long, Component>> cache = new Dictionary<string, Dictionary<long, Component>>();
|
|
|
|
|
|
|
|
public const int taskCount = 32;
|
|
public const int taskCount = 32;
|
|
|
public List<DBTaskQueue> tasks = new List<DBTaskQueue>(taskCount);
|
|
public List<DBTaskQueue> tasks = new List<DBTaskQueue>(taskCount);
|
|
@@ -26,12 +26,12 @@ namespace Model
|
|
|
{
|
|
{
|
|
|
for (int i = 0; i < taskCount; ++i)
|
|
for (int i = 0; i < taskCount; ++i)
|
|
|
{
|
|
{
|
|
|
- DBTaskQueue taskQueue = EntityFactory.Create<DBTaskQueue>();
|
|
|
|
|
|
|
+ DBTaskQueue taskQueue = ComponentFactory.Create<DBTaskQueue>();
|
|
|
this.tasks.Add(taskQueue);
|
|
this.tasks.Add(taskQueue);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public Task<bool> Add(Disposer disposer, string collectionName = "")
|
|
|
|
|
|
|
+ public Task<bool> Add(Component disposer, string collectionName = "")
|
|
|
{
|
|
{
|
|
|
TaskCompletionSource<bool> tcs = new TaskCompletionSource<bool>();
|
|
TaskCompletionSource<bool> tcs = new TaskCompletionSource<bool>();
|
|
|
|
|
|
|
@@ -41,43 +41,43 @@ namespace Model
|
|
|
{
|
|
{
|
|
|
collectionName = disposer.GetType().Name;
|
|
collectionName = disposer.GetType().Name;
|
|
|
}
|
|
}
|
|
|
- DBSaveTask task = EntityFactory.CreateWithId<DBSaveTask, Disposer, string, TaskCompletionSource<bool>>(disposer.Id, disposer, collectionName, tcs);
|
|
|
|
|
|
|
+ DBSaveTask task = ComponentFactory.CreateWithId<DBSaveTask, Component, string, TaskCompletionSource<bool>>(disposer.Id, disposer, collectionName, tcs);
|
|
|
this.tasks[(int)((ulong)task.Id % taskCount)].Add(task);
|
|
this.tasks[(int)((ulong)task.Id % taskCount)].Add(task);
|
|
|
|
|
|
|
|
return tcs.Task;
|
|
return tcs.Task;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public Task<bool> AddBatch(List<Disposer> disposers, string collectionName)
|
|
|
|
|
|
|
+ public Task<bool> AddBatch(List<Component> disposers, string collectionName)
|
|
|
{
|
|
{
|
|
|
TaskCompletionSource<bool> tcs = new TaskCompletionSource<bool>();
|
|
TaskCompletionSource<bool> tcs = new TaskCompletionSource<bool>();
|
|
|
- DBSaveBatchTask task = EntityFactory.Create<DBSaveBatchTask, List<Disposer>, string, TaskCompletionSource<bool>>(disposers, collectionName, tcs);
|
|
|
|
|
|
|
+ DBSaveBatchTask task = ComponentFactory.Create<DBSaveBatchTask, List<Component>, string, TaskCompletionSource<bool>>(disposers, collectionName, tcs);
|
|
|
this.tasks[(int)((ulong)task.Id % taskCount)].Add(task);
|
|
this.tasks[(int)((ulong)task.Id % taskCount)].Add(task);
|
|
|
return tcs.Task;
|
|
return tcs.Task;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public void AddToCache(Disposer disposer, string collectionName = "")
|
|
|
|
|
|
|
+ public void AddToCache(Component disposer, string collectionName = "")
|
|
|
{
|
|
{
|
|
|
if (string.IsNullOrEmpty(collectionName))
|
|
if (string.IsNullOrEmpty(collectionName))
|
|
|
{
|
|
{
|
|
|
collectionName = disposer.GetType().Name;
|
|
collectionName = disposer.GetType().Name;
|
|
|
}
|
|
}
|
|
|
- Dictionary<long, Disposer> collection;
|
|
|
|
|
|
|
+ Dictionary<long, Component> collection;
|
|
|
if (!this.cache.TryGetValue(collectionName, out collection))
|
|
if (!this.cache.TryGetValue(collectionName, out collection))
|
|
|
{
|
|
{
|
|
|
- collection = new Dictionary<long, Disposer>();
|
|
|
|
|
|
|
+ collection = new Dictionary<long, Component>();
|
|
|
this.cache.Add(collectionName, collection);
|
|
this.cache.Add(collectionName, collection);
|
|
|
}
|
|
}
|
|
|
collection[disposer.Id] = disposer;
|
|
collection[disposer.Id] = disposer;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public Disposer GetFromCache(string collectionName, long id)
|
|
|
|
|
|
|
+ public Component GetFromCache(string collectionName, long id)
|
|
|
{
|
|
{
|
|
|
- Dictionary<long, Disposer> d;
|
|
|
|
|
|
|
+ Dictionary<long, Component> d;
|
|
|
if (!this.cache.TryGetValue(collectionName, out d))
|
|
if (!this.cache.TryGetValue(collectionName, out d))
|
|
|
{
|
|
{
|
|
|
return null;
|
|
return null;
|
|
|
}
|
|
}
|
|
|
- Disposer result;
|
|
|
|
|
|
|
+ Component result;
|
|
|
if (!d.TryGetValue(id, out result))
|
|
if (!d.TryGetValue(id, out result))
|
|
|
{
|
|
{
|
|
|
return null;
|
|
return null;
|
|
@@ -87,7 +87,7 @@ namespace Model
|
|
|
|
|
|
|
|
public void RemoveFromCache(string collectionName, long id)
|
|
public void RemoveFromCache(string collectionName, long id)
|
|
|
{
|
|
{
|
|
|
- Dictionary<long, Disposer> d;
|
|
|
|
|
|
|
+ Dictionary<long, Component> d;
|
|
|
if (!this.cache.TryGetValue(collectionName, out d))
|
|
if (!this.cache.TryGetValue(collectionName, out d))
|
|
|
{
|
|
{
|
|
|
return;
|
|
return;
|
|
@@ -95,28 +95,28 @@ namespace Model
|
|
|
d.Remove(id);
|
|
d.Remove(id);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public Task<Disposer> Get(string collectionName, long id)
|
|
|
|
|
|
|
+ public Task<Component> Get(string collectionName, long id)
|
|
|
{
|
|
{
|
|
|
- Disposer disposer = GetFromCache(collectionName, id);
|
|
|
|
|
|
|
+ Component disposer = GetFromCache(collectionName, id);
|
|
|
if (disposer != null)
|
|
if (disposer != null)
|
|
|
{
|
|
{
|
|
|
return Task.FromResult(disposer);
|
|
return Task.FromResult(disposer);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- TaskCompletionSource<Disposer> tcs = new TaskCompletionSource<Disposer>();
|
|
|
|
|
- DBQueryTask dbQueryTask = EntityFactory.CreateWithId<DBQueryTask, string, TaskCompletionSource<Disposer>>(id, collectionName, tcs);
|
|
|
|
|
|
|
+ TaskCompletionSource<Component> tcs = new TaskCompletionSource<Component>();
|
|
|
|
|
+ DBQueryTask dbQueryTask = ComponentFactory.CreateWithId<DBQueryTask, string, TaskCompletionSource<Component>>(id, collectionName, tcs);
|
|
|
this.tasks[(int)((ulong)id % taskCount)].Add(dbQueryTask);
|
|
this.tasks[(int)((ulong)id % taskCount)].Add(dbQueryTask);
|
|
|
|
|
|
|
|
return tcs.Task;
|
|
return tcs.Task;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public Task<List<Disposer>> GetBatch(string collectionName, List<long> idList)
|
|
|
|
|
|
|
+ public Task<List<Component>> GetBatch(string collectionName, List<long> idList)
|
|
|
{
|
|
{
|
|
|
- List <Disposer> disposers = new List<Disposer>();
|
|
|
|
|
|
|
+ List <Component> disposers = new List<Component>();
|
|
|
bool isAllInCache = true;
|
|
bool isAllInCache = true;
|
|
|
foreach (long id in idList)
|
|
foreach (long id in idList)
|
|
|
{
|
|
{
|
|
|
- Disposer disposer = this.GetFromCache(collectionName, id);
|
|
|
|
|
|
|
+ Component disposer = this.GetFromCache(collectionName, id);
|
|
|
if (disposer == null)
|
|
if (disposer == null)
|
|
|
{
|
|
{
|
|
|
isAllInCache = false;
|
|
isAllInCache = false;
|
|
@@ -130,18 +130,18 @@ namespace Model
|
|
|
return Task.FromResult(disposers);
|
|
return Task.FromResult(disposers);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- TaskCompletionSource<List<Disposer>> tcs = new TaskCompletionSource<List<Disposer>>();
|
|
|
|
|
- DBQueryBatchTask dbQueryBatchTask = EntityFactory.Create<DBQueryBatchTask, List<long>, string, TaskCompletionSource<List<Disposer>>>(idList, collectionName, tcs);
|
|
|
|
|
|
|
+ TaskCompletionSource<List<Component>> tcs = new TaskCompletionSource<List<Component>>();
|
|
|
|
|
+ DBQueryBatchTask dbQueryBatchTask = ComponentFactory.Create<DBQueryBatchTask, List<long>, string, TaskCompletionSource<List<Component>>>(idList, collectionName, tcs);
|
|
|
this.tasks[(int)((ulong)dbQueryBatchTask.Id % taskCount)].Add(dbQueryBatchTask);
|
|
this.tasks[(int)((ulong)dbQueryBatchTask.Id % taskCount)].Add(dbQueryBatchTask);
|
|
|
|
|
|
|
|
return tcs.Task;
|
|
return tcs.Task;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public Task<List<Disposer>> GetJson(string collectionName, string json)
|
|
|
|
|
|
|
+ public Task<List<Component>> GetJson(string collectionName, string json)
|
|
|
{
|
|
{
|
|
|
- TaskCompletionSource<List<Disposer>> tcs = new TaskCompletionSource<List<Disposer>>();
|
|
|
|
|
|
|
+ TaskCompletionSource<List<Component>> tcs = new TaskCompletionSource<List<Component>>();
|
|
|
|
|
|
|
|
- DBQueryJsonTask dbQueryJsonTask = EntityFactory.Create<DBQueryJsonTask, string, string, TaskCompletionSource<List<Disposer>>>(collectionName, json, tcs);
|
|
|
|
|
|
|
+ DBQueryJsonTask dbQueryJsonTask = ComponentFactory.Create<DBQueryJsonTask, string, string, TaskCompletionSource<List<Component>>>(collectionName, json, tcs);
|
|
|
this.tasks[(int)((ulong)dbQueryJsonTask.Id % taskCount)].Add(dbQueryJsonTask);
|
|
this.tasks[(int)((ulong)dbQueryJsonTask.Id % taskCount)].Add(dbQueryJsonTask);
|
|
|
|
|
|
|
|
return tcs.Task;
|
|
return tcs.Task;
|