From e00e4e7e75d53af5fcf06a90421f5ca69d35ccf3 Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Sat, 2 Mar 2013 20:28:59 +0400
Subject: LowProfileImageLoader
---
Juick/Classes/LowProfileImageLoader.cs | 294 +++++++++++++++++++++++++++++++++
1 file changed, 294 insertions(+)
create mode 100644 Juick/Classes/LowProfileImageLoader.cs
(limited to 'Juick/Classes/LowProfileImageLoader.cs')
diff --git a/Juick/Classes/LowProfileImageLoader.cs b/Juick/Classes/LowProfileImageLoader.cs
new file mode 100644
index 0000000..d1eb3da
--- /dev/null
+++ b/Juick/Classes/LowProfileImageLoader.cs
@@ -0,0 +1,294 @@
+// Copyright (C) Microsoft Corporation. All Rights Reserved.
+// This code released under the terms of the Microsoft Public License
+// (Ms-PL, http://opensource.org/licenses/ms-pl.html).
+
+using System;
+using System.Collections.Generic;
+using System.ComponentModel;
+using System.Diagnostics.CodeAnalysis;
+using System.IO;
+using System.Net;
+using System.Threading;
+using System.Windows;
+using System.Windows.Controls;
+using System.Windows.Media.Imaging;
+
+namespace Juick.Classes
+{
+ ///
+ /// Provides access to the Image.UriSource attached property which allows
+ /// Images to be loaded by Windows Phone with less impact to the UI thread.
+ ///
+ public static class LowProfileImageLoader
+ {
+ private const int WorkItemQuantum = 5;
+ private static readonly Thread _thread = new Thread(WorkerThreadProc);
+ private static readonly Queue _pendingRequests = new Queue();
+ private static readonly Queue _pendingResponses = new Queue();
+ private static readonly object _syncBlock = new object();
+ private static bool _exiting;
+
+ ///
+ /// Gets the value of the Uri to use for providing the contents of the Image's Source property.
+ ///
+ /// Image needing its Source property set.
+ /// Uri to use for providing the contents of the Source property.
+ [SuppressMessage("Microsoft.Design", "CA1011:ConsiderPassingBaseTypesAsParameters", Justification = "UriSource is applicable only to Image elements.")]
+ public static Uri GetUriSource(Image obj)
+ {
+ if (null == obj)
+ {
+ throw new ArgumentNullException("obj");
+ }
+ return (Uri)obj.GetValue(UriSourceProperty);
+ }
+
+ ///
+ /// Sets the value of the Uri to use for providing the contents of the Image's Source property.
+ ///
+ /// Image needing its Source property set.
+ /// Uri to use for providing the contents of the Source property.
+ [SuppressMessage("Microsoft.Design", "CA1011:ConsiderPassingBaseTypesAsParameters", Justification = "UriSource is applicable only to Image elements.")]
+ public static void SetUriSource(Image obj, Uri value)
+ {
+ if (null == obj)
+ {
+ throw new ArgumentNullException("obj");
+ }
+ obj.SetValue(UriSourceProperty, value);
+ }
+
+ ///
+ /// Identifies the UriSource attached DependencyProperty.
+ ///
+ public static readonly DependencyProperty UriSourceProperty = DependencyProperty.RegisterAttached(
+ "UriSource", typeof(Uri), typeof(LowProfileImageLoader), new PropertyMetadata(OnUriSourceChanged));
+
+ ///
+ /// Gets or sets a value indicating whether low-profile image loading is enabled.
+ ///
+ public static bool IsEnabled { get; set; }
+
+ [SuppressMessage("Microsoft.Performance", "CA1810:InitializeReferenceTypeStaticFieldsInline", Justification = "Static constructor performs additional tasks.")]
+ static LowProfileImageLoader()
+ {
+ // Start worker thread
+ _thread.Start();
+ Application.Current.Exit += new EventHandler(HandleApplicationExit);
+ IsEnabled = true;
+ }
+
+ private static void HandleApplicationExit(object sender, EventArgs e)
+ {
+ // Tell worker thread to exit
+ _exiting = true;
+ if (Monitor.TryEnter(_syncBlock, 100))
+ {
+ Monitor.Pulse(_syncBlock);
+ Monitor.Exit(_syncBlock);
+ }
+ }
+
+ [SuppressMessage("Microsoft.Design", "CA1031:DoNotCatchGeneralExceptionTypes", Justification = "Relevant exceptions don't have a common base class.")]
+ [SuppressMessage("Microsoft.Maintainability", "CA1502:AvoidExcessiveComplexity", Justification = "Linear flow is easy to understand.")]
+ private static void WorkerThreadProc(object unused)
+ {
+ Random rand = new Random();
+ var pendingRequests = new List();
+ var pendingResponses = new Queue();
+ while (!_exiting)
+ {
+ lock (_syncBlock)
+ {
+ // Wait for more work if there's nothing left to do
+ if ((0 == _pendingRequests.Count) && (0 == _pendingResponses.Count) && (0 == pendingRequests.Count) && (0 == pendingResponses.Count))
+ {
+ Monitor.Wait(_syncBlock);
+ if (_exiting)
+ {
+ return;
+ }
+ }
+ // Copy work items to private collections
+ while (0 < _pendingRequests.Count)
+ {
+ var pendingRequest = _pendingRequests.Dequeue();
+ // Search for another pending request for the same Image element
+ for (var i = 0; i < pendingRequests.Count; i++)
+ {
+ if (pendingRequests[i].Image == pendingRequest.Image)
+ {
+ // Found one; replace it
+ pendingRequests[i] = pendingRequest;
+ pendingRequest = null;
+ break;
+ }
+ }
+ if (null != pendingRequest)
+ {
+ // Unique request; add it
+ pendingRequests.Add(pendingRequest);
+ }
+ }
+ while (0 < _pendingResponses.Count)
+ {
+ pendingResponses.Enqueue(_pendingResponses.Dequeue());
+ }
+ }
+ Queue pendingCompletions = new Queue();
+ // Process pending requests
+ var count = pendingRequests.Count;
+ for (var i = 0; (0 < count) && (i < WorkItemQuantum); i++)
+ {
+ // Choose a random item to behave reasonably at both extremes (FIFO/FILO)
+ var index = rand.Next(count);
+ var pendingRequest = pendingRequests[index];
+ pendingRequests[index] = pendingRequests[count - 1];
+ pendingRequests.RemoveAt(count - 1);
+ count--;
+ if (pendingRequest.Uri.IsAbsoluteUri)
+ {
+ // Download from network
+ var webRequest = HttpWebRequest.CreateHttp(pendingRequest.Uri);
+ webRequest.AllowReadStreamBuffering = true; // Don't want to block this thread or the UI thread on network access
+ webRequest.BeginGetResponse(HandleGetResponseResult, new ResponseState(webRequest, pendingRequest.Image, pendingRequest.Uri));
+ }
+ else
+ {
+ // Load from application (must have "Build Action"="Content")
+ var originalUriString = pendingRequest.Uri.OriginalString;
+ // Trim leading '/' to avoid problems
+ var resourceStreamUri = originalUriString.StartsWith("/", StringComparison.Ordinal) ? new Uri(originalUriString.TrimStart('/'), UriKind.Relative) : pendingRequest.Uri;
+ // Enqueue resource stream for completion
+ var streamResourceInfo = Application.GetResourceStream(resourceStreamUri);
+ if (null != streamResourceInfo)
+ {
+ pendingCompletions.Enqueue(new PendingCompletion(pendingRequest.Image, pendingRequest.Uri, streamResourceInfo.Stream));
+ }
+ }
+ // Yield to UI thread
+ Thread.Sleep(1);
+ }
+ // Process pending responses
+ for (var i = 0; (0 < pendingResponses.Count) && (i < WorkItemQuantum); i++)
+ {
+ var pendingResponse = pendingResponses.Dequeue();
+ var responseState = (ResponseState)pendingResponse.AsyncState;
+ try
+ {
+ var response = responseState.WebRequest.EndGetResponse(pendingResponse);
+ pendingCompletions.Enqueue(new PendingCompletion(responseState.Image, responseState.Uri, response.GetResponseStream()));
+ }
+ catch (WebException)
+ {
+ // Ignore web exceptions (ex: not found)
+ }
+ // Yield to UI thread
+ Thread.Sleep(1);
+ }
+ // Process pending completions
+ if (0 < pendingCompletions.Count)
+ {
+ // Get the Dispatcher and process everything that needs to happen on the UI thread in one batch
+ Deployment.Current.Dispatcher.BeginInvoke(() =>
+ {
+ while (0 < pendingCompletions.Count)
+ {
+ // Decode the image and set the source
+ var pendingCompletion = pendingCompletions.Dequeue();
+ if (GetUriSource(pendingCompletion.Image) == pendingCompletion.Uri)
+ {
+ var bitmap = new BitmapImage();
+ try
+ {
+ bitmap.SetSource(pendingCompletion.Stream);
+ }
+ catch
+ {
+ // Ignore image decode exceptions (ex: invalid image)
+ }
+ pendingCompletion.Image.Source = bitmap;
+ }
+ else
+ {
+ // Uri mis-match; do nothing
+ }
+ // Dispose of response stream
+ pendingCompletion.Stream.Dispose();
+ }
+ });
+ }
+ }
+ }
+
+ private static void OnUriSourceChanged(DependencyObject o, DependencyPropertyChangedEventArgs e)
+ {
+ var image = (Image)o;
+ var uri = (Uri)e.NewValue;
+
+ if (!IsEnabled || DesignerProperties.IsInDesignTool)
+ {
+ // Avoid handing off to the worker thread (can cause problems for design tools)
+ image.Source = new BitmapImage(uri);
+ }
+ else
+ {
+ // Clear-out the current image because it's now stale (helps when used with virtualization)
+ image.Source = null;
+ lock (_syncBlock)
+ {
+ // Enqueue the request
+ _pendingRequests.Enqueue(new PendingRequest(image, uri));
+ Monitor.Pulse(_syncBlock);
+ }
+ }
+ }
+
+ private static void HandleGetResponseResult(IAsyncResult result)
+ {
+ lock (_syncBlock)
+ {
+ // Enqueue the response
+ _pendingResponses.Enqueue(result);
+ Monitor.Pulse(_syncBlock);
+ }
+ }
+
+ private class PendingRequest
+ {
+ public Image Image { get; private set; }
+ public Uri Uri { get; private set; }
+ public PendingRequest(Image image, Uri uri)
+ {
+ Image = image;
+ Uri = uri;
+ }
+ }
+
+ private class ResponseState
+ {
+ public WebRequest WebRequest { get; private set; }
+ public Image Image { get; private set; }
+ public Uri Uri { get; private set; }
+ public ResponseState(WebRequest webRequest, Image image, Uri uri)
+ {
+ WebRequest = webRequest;
+ Image = image;
+ Uri = uri;
+ }
+ }
+
+ private class PendingCompletion
+ {
+ public Image Image { get; private set; }
+ public Uri Uri { get; private set; }
+ public Stream Stream { get; private set; }
+ public PendingCompletion(Image image, Uri uri, Stream stream)
+ {
+ Image = image;
+ Uri = uri;
+ Stream = stream;
+ }
+ }
+ }
+}
--
cgit v1.2.3