ToxicMushroom/Dalamud
1
0
Fork 0
mirror of https://github.com/goatcorp/Dalamud.git synced 2025-12-12 18:27:23 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

fix(PluginImageCache): use thread instead of taks

Browse source
This commit is contained in:
goaaats 2021-12-04 15:17:05 +01:00
parent 47a2287e83
commit 08b0bc94c4
No known key found for this signature in database
GPG key ID: F18F057873895461
1 changed files with 12 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

23
Dalamud/Interface/Internal/Windows/PluginImageCache.cs
View file

@ -45,6 +45,7 @@ namespace Dalamud.Interface.Internal.Windows
private BlockingCollection<Func<Task>> downloadQueue = new();
private CancellationTokenSource downloadToken = new();
private Thread downloadThread;
private Dictionary<string, TextureWrap?> pluginIconMap = new();
private Dictionary<string, TextureWrap?[]> pluginImagesMap = new();
@ -61,11 +62,8 @@ namespace Dalamud.Interface.Internal.Windows
this.TroubleIcon = interfaceManager.LoadImage(Path.Combine(dalamud.AssetDirectory.FullName, "UIRes", "troubleIcon.png"));
this.UpdateIcon = interfaceManager.LoadImage(Path.Combine(dalamud.AssetDirectory.FullName, "UIRes", "updateIcon.png"));
var task = new Task(
() => this.DownloadTask(this.downloadToken.Token),
this.downloadToken.Token,
TaskCreationOptions.LongRunning);
task.Start();
this.downloadThread = new Thread(this.DownloadTask);
this.downloadThread.Start();
}
/// <summary>
@ -91,6 +89,12 @@ namespace Dalamud.Interface.Internal.Windows
this.UpdateIcon?.Dispose();
this.downloadToken?.Cancel();
if (!this.downloadThread.Join(4000))
{
Log.Error("Plugin Image Download thread has not cancelled in time.");
}
this.downloadToken?.Dispose();
this.downloadQueue?.CompleteAdding();
this.downloadQueue?.Dispose();
@ -171,16 +175,13 @@ namespace Dalamud.Interface.Internal.Windows
return false;
}
private async void DownloadTask(CancellationToken token)
private async void DownloadTask()
{
while (true)
while (!this.downloadToken.Token.IsCancellationRequested)
{
try
{
if (token.IsCancellationRequested)
return;
if (!this.downloadQueue.TryTake(out var task, -1, token))
if (!this.downloadQueue.TryTake(out var task, -1, this.downloadToken.Token))
return;
await task.Invoke();