Project Name File Name Usage Source Code Link
RazorEngine TemplateServiceTestFixture.cs ThreadPool.QueueUserWorkItem(item.ThreadPoolCallback) Link To Source File
lucene.net TestStringIntern.cs ThreadPool.QueueUserWorkItem(new WaitCallback(threads[i].Run)) Link To Source File
Agents ThreadPoolScheduler.cs ThreadPool.QueueUserWorkItem((o) => { if (!_disposed) action(); }) Link To Source File
Agents BatchWriter.cs ThreadPool.QueueUserWorkItem(callback) Link To Source File
Agents NoWaitProducerConsumentCollectionTests.cs ThreadPool.QueueUserWorkItem( x => { foreach (var i in Range(size).AsParallel()) { queue.Add(i); } }) Link To Source File
Agents WaitQueueTests.cs ThreadPool.QueueUserWorkItem( x => { foreach (var i in Range(size).AsParallel()) { queue.Add(i); } }) Link To Source File
SystemWrapper ThreadPoolWrap.cs ThreadPool.QueueUserWorkItem(callBack) Link To Source File
ASP.NET-Mvc-3 ReflectedAsyncActionDescriptor.cs ThreadPool.QueueUserWorkItem(_ => asyncResult.MarkCompleted(false /* completedSynchronously */, asyncCallback)) Link To Source File
ASP.NET-Mvc-3 AsyncManagerExtensionsTest.cs ThreadPool.QueueUserWorkItem(_ => { Assert.AreEqual(1, asyncManager.OutstandingOperations.Count, "Counter shouldn't have been decremented yet."); callback(asyncResult); waitHandle.Set(); }) Link To Source File
ASP.NET-Mvc-3 AsyncManagerExtensionsTest.cs ThreadPool.QueueUserWorkItem(_ => { callback(asyncResult); waitHandle.Set(); }) Link To Source File
ASP.NET-Mvc-3 ApplicationStartPage.cs ThreadPool.QueueUserWorkItem(new WaitCallback(ShutdownCallBack)) Link To Source File
AutoMapper ConcurrentHashtable.cs ThreadPool.QueueUserWorkItem(AssessSegmentation) Link To Source File
AutoMapper ConcurrentHashtable.cs ThreadPool.QueueUserWorkItem(AssessSegmentation) Link To Source File
sable-fx 3 Sockets.cs ThreadPool.QueueUserWorkItem(RunClient) Link To Source File
WCFQuickSamples Program.cs ThreadPool.QueueUserWorkItem(delegate { c.CallService(); }) Link To Source File
WCFQuickSamples Program.cs ThreadPool.QueueUserWorkItem(delegate { c.CallService(); }) Link To Source File
WCFQuickSamples Program.cs ThreadPool.QueueUserWorkItem(delegate { Console.WriteLine("[{0}] At server, calling operation on client {1}", Thread.CurrentThread.ManagedThreadId, clientName); string result = callback.EchoAtClient("Hello " + clientName); Console.WriteLine("[{0}] At server, client {1} replied: {2}", Thread.CurrentThread.ManagedThreadId, clientName, result); }) Link To Source File
WCFQuickSamples Program.cs ThreadPool.QueueUserWorkItem(delegate { for (int i = 0; i < numberOfTimes; i++) { Console.WriteLine("Received from client: {0}", callback.Hello("Server")); } }) Link To Source File
WCFQuickSamples Templates.cs ThreadPool.QueueUserWorkItem(delegate { callback.OnHello(text); }) Link To Source File
babelim LoginViewModel.cs ThreadPool.QueueUserWorkItem ( new WaitCallback ( delegate { // Build the connection string IXmppSession session = ServiceFactory.Current.Resolve(); XmppConnectionStringBuilder builder = new XmppConnectionStringBuilder(); BabelImConfiguration configuration = ServiceFactory.Current.Resolve().GetConfiguration(); if (this.selectedAccount != null && configuration.Servers[this.selectedAccount.Server] != null) { builder.UserId = String.Format ( "{0}@{1}/{2}", this.Login, configuration.Servers[this.selectedAccount.Server].DomainName, this.selectedAccount.Resource ); Server serverInfo = configuration.Servers[this.selectedAccount.Server]; builder.HostName = serverInfo.ServerName; builder.Port = serverInfo.PortNumber; builder.Password = this.Password; builder.UseProxy = serverInfo.UseProxy; builder.ProxyServer = serverInfo.ProxyServer; builder.ProxyPortNumber = serverInfo.ProxyPortNumber; builder.ProxyType = serverInfo.ProxyType; builder.ProxyUserName = serverInfo.ProxyUserName; builder.ProxyPassword = serverInfo.ProxyPassword; builder.ResolveHostName = serverInfo.ResolveHostName; builder.UseHttpBinding = serverInfo.UseHttpBinding; // Set client capabilities session.Capabilities.Node = configuration.General.Capabilities.URI; session.Capabilities.Name = configuration.General.Capabilities.Name; session.Capabilities.Version = configuration.General.Capabilities.Version; session.PersonalEventing.IsUserTuneEnabled = configuration.General.UserTuneEnabled; session.Capabilities.Identities.Add ( new XmppServiceIdentity ( configuration.General.Capabilities.Name, configuration.General.Capabilities.IdentityCategory, configuration.General.Capabilities.IdentityType ) ); session.Open(builder.ToString()); } } ) ) Link To Source File
Castle.Windsor-READONLY LazyLoadingTestCase.cs ThreadPool.QueueUserWorkItem(o => { try { Container.Resolve("not registered"); if (Interlocked.Decrement(ref count[0]) == 0) { @event.Set(); } } catch (Exception e) { exception = e; // this is required because NUnit does not consider it a failure when // an exception is thrown on a non-main thread and therfore it waits. @event.Set(); } } ) Link To Source File
Windsor LazyLoadingTestCase.cs ThreadPool.QueueUserWorkItem(o => { try { Container.Resolve("not registered"); if (Interlocked.Decrement(ref count[0]) == 0) { @event.Set(); } } catch (Exception e) { exception = e; // this is required because NUnit does not consider it a failure when // an exception is thrown on a non-main thread and therfore it waits. @event.Set(); } } ) Link To Source File
Lokad.Cloud MainForm.cs // Do this asynchronously because it requires a few seconds ThreadPool.QueueUserWorkItem(new WaitCallback((s) => { using(var input = (Bitmap)Bitmap.FromFile(_currentFileName)) { var slices = Helpers.SliceBitmapAsPng(input, 14); // Queue slices _mapReduceJob.PushItems(new HistogramMapReduceFunctions(), slices, 4); //_currentHistogram = Helpers.ComputeHistogram(input); //_pnlHistogram.Refresh(); } BeginInvoke(new Action(() => _timer.Start())); })) Link To Source File
Lokad.Cloud MainForm.cs ThreadPool.QueueUserWorkItem(new WaitCallback((s) => { // Check job status bool completed = _mapReduceJob.IsCompleted(); if(completed) { _currentHistogram = _mapReduceJob.GetResult(); _mapReduceJob.DeleteJobData(); } BeginInvoke(new Action(() => { if(completed) { _pnlHistogram.Refresh(); _btnStart.Enabled = true; _btnBrowse.Enabled = true; _prgProgress.Style = ProgressBarStyle.Blocks; } else _timer.Start(); })); })) Link To Source File
sider MonitorExecutor.cs ThreadPool.QueueUserWorkItem(monitorThread) Link To Source File
sider PubSubExecutor.cs ThreadPool.QueueUserWorkItem(pubsubCore) Link To Source File
sshnet ChannelDirectTcpip.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet ForwardedPortLocal.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet ForwardedPortRemote.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet KeyboardInteractiveConnectionInfo.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet PasswordConnectionInfo.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet Session.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet SftpClient.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet Shell.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet SshCommand.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet ForwardedPortLocal.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet ForwardedPortRemote.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet PasswordConnectionInfo.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet Session.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet SftpClient.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet SshCommand.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
sshnet TestPortForwarding.cs System.Threading.ThreadPool.QueueUserWorkItem(delegate(object state) { try { var url = "http://www.google.com/"; Debug.WriteLine("Starting web request to /"" + url + "/""); HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(url); HttpWebResponse response = (HttpWebResponse)request.GetResponse(); Assert.IsNotNull(response); Debug.WriteLine("Http Response status code: " + response.StatusCode.ToString()); response.Close(); hasTestedTunnel = true; } catch (Exception ex) { Assert.Fail(ex.ToString()); } }) Link To Source File
sshnet TestPortForwarding.cs // Try stop the port forwarding, wait 3 seconds and fail if it is still started. System.Threading.ThreadPool.QueueUserWorkItem(delegate(object state) { Debug.WriteLine("Trying to stop port forward."); port1.Stop(); Debug.WriteLine("Port forwarding stopped."); }) Link To Source File
Fibrous DefaultThreadPool.cs System.Threading.ThreadPool.QueueUserWorkItem(callback) Link To Source File
dextop LongPollingQueue.cs ThreadPool.QueueUserWorkItem(Notify) Link To Source File
localtunnel-net-client ChannelDirectTcpip.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client ForwardedPortLocal.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client ForwardedPortRemote.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client KeyboardInteractiveConnectionInfo.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client PasswordConnectionInfo.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client Session.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client SftpClient.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client Shell.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client SshCommand.NET35.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client ForwardedPortLocal.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client ForwardedPortRemote.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client PasswordConnectionInfo.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client Session.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client SftpClient.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client SshCommand.SilverlightShared.cs ThreadPool.QueueUserWorkItem((o) => { action(); }) Link To Source File
localtunnel-net-client TestPortForwarding.cs System.Threading.ThreadPool.QueueUserWorkItem(delegate(object state) { try { var url = "http://www.google.com/"; Debug.WriteLine("Starting web request to /"" + url + "/""); HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(url); HttpWebResponse response = (HttpWebResponse)request.GetResponse(); Assert.IsNotNull(response); Debug.WriteLine("Http Response status code: " + response.StatusCode.ToString()); response.Close(); hasTestedTunnel = true; } catch (Exception ex) { Assert.Fail(ex.ToString()); } }) Link To Source File
localtunnel-net-client TestPortForwarding.cs // Try stop the port forwarding, wait 3 seconds and fail if it is still started. System.Threading.ThreadPool.QueueUserWorkItem(delegate(object state) { Debug.WriteLine("Trying to stop port forward."); port1.Stop(); Debug.WriteLine("Port forwarding stopped."); }) Link To Source File
fubumvc ApplicationRunner.cs // Put a thread here ThreadPool.QueueUserWorkItem(o => { // Need to make this capture the package registry failures cleanly _kayakApplication.RunApplication(settings.Port, r => reset.Set()); }) Link To Source File
fubumvc Listener.cs ThreadPool.QueueUserWorkItem(o => action()) Link To Source File
Tempest ClientBase.cs ThreadPool.QueueUserWorkItem (s => { Thread runner = this.messageRunner; if (runner != null) runner.Join(); this.messageRunner = null; }) Link To Source File
Tempest NetworkConnection.cs ThreadPool.QueueUserWorkItem (s => { this.pkAuthentication = this.publicKeyCryptoFactory(); if (this.authenticationKey == null) { if (generateKey) { this.publicAuthenticationKey = this.pkAuthentication.ExportKey (false); this.authenticationKey = this.pkAuthentication.ExportKey (true); } } else { this.pkAuthentication.ImportKey (authKey); this.publicAuthenticationKey = this.pkAuthentication.ExportKey (false); } this.authReady = true; }) Link To Source File
Tempest NetworkConnectionProvider.cs ThreadPool.QueueUserWorkItem (s => { #if NET_4 Task encryptKeyGen = Task.Factory.StartNew (() => { #endif this.pkEncryption = this.pkCryptoFactory(); this.publicEncryptionKey = this.pkEncryption.ExportKey (false); #if NET_4 }); #endif #if NET_4 Task authKeyGen = Task.Factory.StartNew (() => { #endif this.authentication = this.pkCryptoFactory(); if (this.authenticationKey == null) this.authenticationKey = this.authentication.ExportKey (true); else this.authentication.ImportKey (this.authenticationKey); this.publicAuthenticationKey = this.authentication.ExportKey (false); if (enabledHashAlgs == null || !enabledHashAlgs.Any()) this.enabledHashAlgorithms.AddRange (this.authentication.SupportedHashAlgs); else // Need to maintain preference order this.enabledHashAlgorithms.AddRange (enabledHashAlgs.Where (a => this.authentication.SupportedHashAlgs.Contains (a))); #if NET_4 }); authKeyGen.Wait(); encryptKeyGen.Wait(); #endif this.keyWait.Set(); }) Link To Source File
OncRpc UdpSession.cs ThreadPool.QueueUserWorkItem(BuildMessage) Link To Source File
OncRpc TcpSession.cs ThreadPool.QueueUserWorkItem(BuildMessage) Link To Source File
OncRpc TcpClientWrapper.cs ThreadPool.QueueUserWorkItem(_ => completed(ex)) Link To Source File
OncRpc TcpClientWrapper.cs ThreadPool.QueueUserWorkItem((state) => completed(ex, null)) Link To Source File
OncRpc TcpClientWrapper.cs ThreadPool.QueueUserWorkItem((state) => completed(ex)) Link To Source File
OncRpc UdpClientWrapper.cs ThreadPool.QueueUserWorkItem((state) => completed(ex, null)) Link To Source File
OncRpc UdpClientWrapper.cs ThreadPool.QueueUserWorkItem((state) => completed(ex)) Link To Source File
Filechronization Program.cs ThreadPool.QueueUserWorkItem(delegate(object o) {Application.Run(splash);}) Link To Source File
CityIndexScreensaver Data.cs ThreadPool.QueueUserWorkItem(x => SubscribeNewsThreadEntry(onUpdate)) Link To Source File
CityIndexScreensaver Data.cs ThreadPool.QueueUserWorkItem(x => SubscribePricesThreadEntry(id, onUpdate)) Link To Source File
CityIndexScreensaver Data.cs ThreadPool.QueueUserWorkItem(x => GetMarketsListThreadEntry(onSuccess)) Link To Source File
CityIndexScreensaver Data.cs ThreadPool.QueueUserWorkItem( x => { try { EnsureConnectionSync(); Callback(onSuccess); } catch (Exception exc) { Callback(onError); ReportError(exc); } }) Link To Source File
CityIndexScreensaver Data.cs ThreadPool.QueueUserWorkItem( x => { try { LogoutSync(); Callback(onSuccess); } catch (Exception exc) { ReportError(exc); } }) Link To Source File
Tardis HttpServer.cs ThreadPool.QueueUserWorkItem(callBack) Link To Source File
MvcPerf ReflectedAsyncActionDescriptor.cs ThreadPool.QueueUserWorkItem(_ => asyncResult.MarkCompleted(false /* completedSynchronously */, asyncCallback)) Link To Source File
MvcPerf AsyncManagerExtensionsTest.cs ThreadPool.QueueUserWorkItem(_ => { Assert.AreEqual(1, asyncManager.OutstandingOperations.Count, "Counter shouldn't have been decremented yet."); callback(asyncResult); waitHandle.Set(); }) Link To Source File
MvcPerf AsyncManagerExtensionsTest.cs ThreadPool.QueueUserWorkItem(_ => { callback(asyncResult); waitHandle.Set(); }) Link To Source File
MvcPerf ApplicationStartPage.cs ThreadPool.QueueUserWorkItem(new WaitCallback(ShutdownCallBack)) Link To Source File
thingmagic Reader.cs ThreadPool.QueueUserWorkItem(callback.ThreadPoolCallBack) Link To Source File
ILSpy CSDemo.cs ThreadPool.QueueUserWorkItem( delegate { builtInLibs.Value.ToString(); BeginInvoke(new Action(delegate { resolveButton.UseWaitCursor = false; })); }) Link To Source File
NRefactory CSDemo.cs ThreadPool.QueueUserWorkItem( delegate { builtInLibs.Value.ToString(); BeginInvoke(new Action(delegate { resolveButton.UseWaitCursor = false; })); }) Link To Source File
SharpDevelop MainForm.cs System.Threading.ThreadPool.QueueUserWorkItem(ThreadedRun) Link To Source File
SharpDevelop Task.cs // already complete: start action immediately (but on another thread!) ThreadPool.QueueUserWorkItem(state => action()) Link To Source File
SharpDevelop NewLineConsistencyCheck.cs ThreadPool.QueueUserWorkItem(c.CheckNewLinesForConsistency) Link To Source File
SharpDevelop AnalyticsMonitor.cs // Initially opening the session takes some time; which is bad for the startpage // because the animation would start with a delay. We solve this by calling Open/CloseSession // on a background thread. ThreadPool.QueueUserWorkItem(delegate { AsyncEnableDisable(); } ) Link To Source File
SharpDevelop AnalyticsMonitor.cs ThreadPool.QueueUserWorkItem(delegate { uploader.StartUpload(UploadUrl); }) Link To Source File
SharpDevelop OverlayIconManager.cs ThreadPool.QueueUserWorkItem(Run) Link To Source File
SharpDevelop OverlayIconManager.cs ThreadPool.QueueUserWorkItem(Run) Link To Source File
SharpDevelop OverlayIconManager.cs ThreadPool.QueueUserWorkItem(Run) Link To Source File
SharpDevelop InfoPanel.cs ThreadPool.QueueUserWorkItem(LoadChangedPaths) Link To Source File
SharpDevelop OverlayIconManager.cs ThreadPool.QueueUserWorkItem(Run) Link To Source File
SharpDevelop OverlayIconManager.cs ThreadPool.QueueUserWorkItem(Run) Link To Source File
SharpDevelop BuildEngine.cs // do not run "DoStartBuild" inside lock - run it async on the thread pool System.Threading.ThreadPool.QueueUserWorkItem(node.DoStartBuild) Link To Source File
NETGen TwitterStream.cs System.Threading.ThreadPool.QueueUserWorkItem(new System.Threading.WaitCallback(stream)) Link To Source File
NETGen DiscreteDynamics.cs System.Threading.ThreadPool.QueueUserWorkItem(new System.Threading.WaitCallback( delegate(object o) { Run(); })) Link To Source File
NETGen ContinuousDynamics.cs System.Threading.ThreadPool.QueueUserWorkItem(new System.Threading.WaitCallback( delegate(object o) { Run(); })) Link To Source File
NETGen ILayoutProvider.cs System.Threading.ThreadPool.QueueUserWorkItem(delegate(object o) { DoLayout(); if(layoutCompleted!=null) layoutCompleted(); }) Link To Source File
MiniTwitter-Mod TextViewer.xaml.cs ThreadPool.QueueUserWorkItem(_ => CacheUrl(url, uriFactory(url))) Link To Source File
MiniTwitter-Mod TextViewer.xaml.cs ThreadPool.QueueUserWorkItem(_ => CacheUrl(url, uriFactory())) Link To Source File
MiniTwitter-Mod MainWindow.xaml.cs ThreadPool.QueueUserWorkItem(LoginCallback) Link To Source File
MiniTwitter-Mod SettingDialog.xaml.cs ThreadPool.QueueUserWorkItem(_ => text.Invoke(() => text.FontFamily = (FontFamily)text.Tag)) Link To Source File
Craig-s-Utility-Library ProcessExtensions.cs ThreadPool.QueueUserWorkItem(delegate { KillProcessAsyncHelper(Process, TimeToKill); }) Link To Source File
Craig-s-Utility-Library ProcessExtensions.cs ThreadPool.QueueUserWorkItem(delegate { KillProcessAsyncHelper(x, TimeToKill); }) Link To Source File
Craig-s-Utility-Library EmailSender.cs ThreadPool.QueueUserWorkItem(delegate { SendMail(); }) Link To Source File
Craig-s-Utility-Library EmailSender.cs ThreadPool.QueueUserWorkItem(delegate { SendMail(); }) Link To Source File
Craig-s-Utility-Library Manager.cs ThreadPool.QueueUserWorkItem(delegate { PingServices(Services, Blog, BlogName); }) Link To Source File
Craig-s-Utility-Library ProcessExtensions.cs ThreadPool.QueueUserWorkItem(delegate { KillProcessAsyncHelper(Process, TimeToKill); }) Link To Source File
Craig-s-Utility-Library ProcessExtensions.cs ThreadPool.QueueUserWorkItem(delegate { KillProcessAsyncHelper(x, TimeToKill); }) Link To Source File
Craig-s-Utility-Library EmailSender.cs ThreadPool.QueueUserWorkItem(delegate { SendMail(); }) Link To Source File
Craig-s-Utility-Library EmailSender.cs ThreadPool.QueueUserWorkItem(delegate { SendMail(); }) Link To Source File
Craig-s-Utility-Library Manager.cs ThreadPool.QueueUserWorkItem(delegate { PingServices(Services, Blog, BlogName); }) Link To Source File
OCTGN Server.cs ThreadPool.QueueUserWorkItem(delegate { if (!_shutdownInProgress) { var conn = new Connection( this, acceptedSocket); if ( conn. WaitForRequestBytes () == 0) { conn. WriteErrorAndClose (400); return; } Host host = GetHostAndInjectAssemblies (); if (host == null) { conn. WriteErrorAndClose (500); return; } IncrementRequestCount(); host.ProcessRequest( conn); } }) Link To Source File
OCTGN Server.cs ThreadPool.QueueUserWorkItem(delegate { if (!_shutdownInProgress) { var conn = new Connection( this, acceptedSocket); if ( conn. WaitForRequestBytes () == 0) { conn. WriteErrorAndClose (400); return; } Host host = GetHost(); if (host == null) { conn. WriteErrorAndClose (500); return; } IncrementRequestCount(); host.ProcessRequest( conn); } }) Link To Source File
OCTGN PatchDialog.xaml.cs ThreadPool.QueueUserWorkItem( _ => patch.Apply(Program.GamesRepository, patchInstalledSets, targetFolder)) Link To Source File
Fracture Misc.cs ThreadPool.QueueUserWorkItem( (WaitCallback)( (state) => { try { object result; result = cmd.ExecuteScalar(); f.SetResult(result, null); } catch (Exception e) { f.Fail(e); } } ) ) Link To Source File
Fracture Misc.cs ThreadPool.QueueUserWorkItem( (WaitCallback)( (state) => { try { int result; result = cmd.ExecuteNonQuery(); f.SetResult(result, null); } catch (Exception e) { f.Fail(e); } } ) ) Link To Source File
Fracture Misc.cs ThreadPool.QueueUserWorkItem( (WaitCallback)( (state) => { try { IDataReader result; result = cmd.ExecuteReader(); f.SetResult(result, null); } catch (Exception e) { f.Fail(e); } } ) ) Link To Source File
Fracture Web.cs ThreadPool.QueueUserWorkItem( (__) => { try { request.BeginGetResponse( (ar) => { try { var _ = (HttpWebResponse)request.EndGetResponse(ar); fResponse.SetResult(_, null); } catch (Exception ex) { fResponse.SetResult(null, ex); } }, null ); } catch (Exception ex_) { fResponse.SetResult(null, ex_); } } ) Link To Source File
OrchardApp DefaultAsyncTokenProvider.cs // Start a work item to collect tokens in our internal array ThreadPool.QueueUserWorkItem(state => { try { _task(token => _taskTokens.Add(token)); } catch (Exception e) { Logger.Error(e, "Error while monitoring extension files. Assuming extensions are not current."); _taskException = e; } finally { _isTaskFinished = true; } }) Link To Source File
lokad-cloud MainForm.cs ThreadPool.QueueUserWorkItem(s => { // Check job status bool completed = _mapReduceJob.IsCompleted(); if (completed) { _currentHistogram = _mapReduceJob.GetResult(); _mapReduceJob.DeleteJobData(); } BeginInvoke(new Action(() => { if (completed) { _pnlHistogram.Refresh(); _btnStart.Enabled = true; _btnBrowse.Enabled = true; _prgProgress.Style = ProgressBarStyle.Blocks; } else _timer.Start(); })); }) Link To Source File
LoreSoft.Shared CacheItem.cs // run async ThreadPool.QueueUserWorkItem(s => handle(this)) Link To Source File
CaveTalk WebSocket.cs ThreadPool.QueueUserWorkItem(obj => Message()) Link To Source File
SIinformer DownloadEngine.cs ThreadPool.QueueUserWorkItem(new WaitCallback(this.ProcDownload)) Link To Source File
SIinformer DownloadProgress.cs ThreadPool.QueueUserWorkItem(new WaitCallback(this.ProcDownload)) Link To Source File
nuget InteractiveHelper.cs ThreadPool.QueueUserWorkItem( state => { Thread.Sleep(timeout); dispatcher.CancelWaitKey(); }) Link To Source File
SuperSocket IAsyncRunner.cs ThreadPool.QueueUserWorkItem(delegate { ExecuteAsyncInternal(callback, exceptionCallback); }) Link To Source File
cleanLayer ScriptManager.cs ThreadPool.QueueUserWorkItem((state) => Compile()) Link To Source File
EasyNetQ SharedQueueSpike.cs ThreadPool.QueueUserWorkItem(state => { // expect the queue to block here Console.WriteLine("Dequeue in thread"); try { var item2 = queue.Dequeue().ToString(); } catch (Exception e) { Console.WriteLine("Exception in thread/n{0}", e.ToString()); } }) Link To Source File
EasyNetQ TaskCompletionSourceSpike.cs ThreadPool.QueueUserWorkItem(_ => { try { var result = func(); tcs.SetResult(result); } catch (Exception exception) { tcs.SetException(exception); } }) Link To Source File
WebStresser RawHttpClient.cs ThreadPool.QueueUserWorkItem(ExecuteRequests) Link To Source File
orchard DefaultAsyncTokenProvider.cs // Start a work item to collect tokens in our internal array ThreadPool.QueueUserWorkItem(state => { try { _task(token => _taskTokens.Add(token)); } catch (Exception e) { Logger.Error(e, "Error while monitoring extension files. Assuming extensions are not current."); _taskException = e; } finally { _isTaskFinished = true; } }) Link To Source File
monodevelop WaitDialog.cs ThreadPool.QueueUserWorkItem (new WaitCallback (ProgressUpdate)) Link To Source File
monodevelop TableEditorDialog.cs ThreadPool.QueueUserWorkItem (new WaitCallback (InitializeThreaded)) Link To Source File
monodevelop GdbSession.cs ThreadPool.QueueUserWorkItem (delegate { try { HandleEvent (ev); } catch (Exception ex) { Console.WriteLine (ex); } }) Link To Source File
monodevelop DebuggerServer.cs ST.ThreadPool.QueueUserWorkItem (delegate { // Run in a thread to avoid a deadlock, since NotifyStarted calls back to the client. NotifyStarted (); debugger.Run(session); }) Link To Source File
monodevelop DebuggerServer.cs ST.ThreadPool.QueueUserWorkItem (delegate { NotifyStarted (); }) Link To Source File
monodevelop CorDebuggerSession.cs ThreadPool.QueueUserWorkItem (delegate { if (process != null) { // Process already running. Stop it. In the ProcessExited event the // debugger engine will be terminated process.Stop (4000); process.Terminate (1); } }) Link To Source File
monodevelop CorDebuggerSession.cs ThreadPool.QueueUserWorkItem (delegate { // The Terminate call will fail if called in the event handler dbg.Terminate (); dbg = null; GC.Collect (); }) Link To Source File
monodevelop PythonSite.cs ThreadPool.QueueUserWorkItem (delegate { m_Database.RemoveByFilePrefix (path); }) Link To Source File
monodevelop ParserDatabase.cs // Copy the database in a thread ThreadPool.QueueUserWorkItem (delegate { try { this.CopyDatabase (conn); } catch (Exception ex) { Console.WriteLine (ex.ToString ()); } conn.Close (); conn.Dispose (); if (File.Exists (backup)) File.Delete (backup); }) Link To Source File
monodevelop Executors.cs ThreadPool.QueueUserWorkItem (delegate { future.Run (c); }) Link To Source File
monodevelop SoftDebuggerSession.cs ThreadPool.QueueUserWorkItem (delegate { // This is a workaround for a mono bug // Without this call, the process may become zombie in mono < 2.10.2 vm.Process.WaitForExit (); }) Link To Source File
monodevelop RefactoryCommands.cs ThreadPool.QueueUserWorkItem (FindReferencesThread) Link To Source File
monodevelop RefactoryCommands.cs ThreadPool.QueueUserWorkItem (FindDerivedThread) Link To Source File
monodevelop SelectRepositoryDialog.cs ThreadPool.QueueUserWorkItem (delegate { LoadRepoInfo (parent, repoIter, citer); }) Link To Source File
monodevelop Task.cs ThreadPool.QueueUserWorkItem (BackgroundWorker) Link To Source File
monodevelop VersionControlService.cs ThreadPool.QueueUserWorkItem (DelayedSaveComments) Link To Source File
monodevelop GitService.cs System.Threading.ThreadPool.QueueUserWorkItem (delegate { try { repo.Push (monitor, remote, branch); } catch (Exception ex) { monitor.ReportError (ex.Message, ex); } finally { monitor.Dispose (); } }) Link To Source File
monodevelop GitService.cs System.Threading.ThreadPool.QueueUserWorkItem (delegate { try { repo.SwitchToBranch (monitor, branch); } catch (Exception ex) { monitor.ReportError ("Branch switch failed", ex); } finally { monitor.Dispose (); } }) Link To Source File
monodevelop DebuggerSession.cs ThreadPool.QueueUserWorkItem (delegate { OnCancelAsyncEvaluations (); }) Link To Source File
monodevelop ObjectValue.cs // Do the callback connection in a background thread System.Threading.ThreadPool.QueueUserWorkItem (delegate { foreach (KeyValuePair> cbs in callbacks) { cbs.Key.RegisterUpdateCallbacks (cbs.Value.ToArray ()); } }) Link To Source File
monodevelop ProcessHostController.cs ThreadPool.QueueUserWorkItem (delegate { try { processHost.DisposeObject ((IDisposable)obj); } catch { } ReleaseInstance (obj); }) Link To Source File
monodevelop ProcessHostController.cs ThreadPool.QueueUserWorkItem (delegate { try { process.Cancel (); } catch { } }) Link To Source File
monodevelop DisposerFormatterSink.cs ThreadPool.QueueUserWorkItem (delegate { res = ((IMessageSink)nextSink).SyncProcessMessage (msg); }) Link To Source File
monodevelop HelpService.cs ThreadPool.QueueUserWorkItem (delegate { // Load the help tree asynchronously. Reduces startup time. InitializeHelpTree (); }) Link To Source File
monodevelop CrashMonitor.cs // Wait for the parent MD process to exit. This could be a crash // or a graceful exit. ThreadPool.QueueUserWorkItem (o => { // Do a loop rather than calling WaitForExit or hooking into // the Exited event as those do not work on MacOS on mono 2.10.3 var info = System.Diagnostics.Process.GetProcessById (Pid); while (!info.HasExited) { Thread.Sleep (1000); info.Refresh (); } // If the application has crashed we want to wait a few seconds before // raising this event so we allow time for the native crash reporter to // write its log files. Thread.Sleep (5000); OnApplicationExited (); }) Link To Source File
monodevelop NavigateToDialog.cs ThreadPool.QueueUserWorkItem (delegate { files = GetFiles (); }) Link To Source File
NugetCracker InteractiveHelper.cs ThreadPool.QueueUserWorkItem( state => { Thread.Sleep(timeout); dispatcher.CancelWaitKey(); }) Link To Source File
Disruptor-net Pipeline3StepBlockingCollectionPerfTest.cs ThreadPool.QueueUserWorkItem(_ => _stepOneQueueEventProcessor.Run()) Link To Source File
Disruptor-net Pipeline3StepBlockingCollectionPerfTest.cs ThreadPool.QueueUserWorkItem(_ => _stepTwoQueueEventProcessor.Run()) Link To Source File
Disruptor-net Pipeline3StepBlockingCollectionPerfTest.cs ThreadPool.QueueUserWorkItem(_ => _stepThreeQueueEventProcessor.Run()) Link To Source File
OG-DotNet Invalidater.cs ThreadPool.QueueUserWorkItem(Rebuild) Link To Source File
OG-DotNet MarketDataSnapshotProcessorTests.cs ThreadPool.QueueUserWorkItem(delegate { Thread.Sleep(when); cts.Cancel(); }) Link To Source File
Automapper ConcurrentHashtable.cs ThreadPool.QueueUserWorkItem(AssessSegmentation) Link To Source File
Automapper ConcurrentHashtable.cs ThreadPool.QueueUserWorkItem(AssessSegmentation) Link To Source File
kudu ProxyService.cs ThreadPool.QueueUserWorkItem(_ => { try { _deploymentManager.Deploy(); } catch (Exception ex) { Debug.WriteLine("Error deploying"); Debug.WriteLine(ex.Message); } }) Link To Source File
preprompt-parallel BinaryTree.cs ThreadPool.QueueUserWorkItem(x => { WalkPar(root.Left, action); cte.Signal(); }) Link To Source File
preprompt-parallel BinaryTree.cs ThreadPool.QueueUserWorkItem(x => { WalkPar(root.Right, action); cte.Signal(); }) Link To Source File
ravendb TransactionalStorage.cs ThreadPool.QueueUserWorkItem(backupOperation.Execute) Link To Source File
ravendb TransactionalStorage.cs ThreadPool.QueueUserWorkItem(backupOperation.Execute) Link To Source File
ravendb ParallelDeflateOutputStream.cs ThreadPool.QueueUserWorkItem(new WaitCallback(this._PerpetualWriterMethod)) Link To Source File
MonoMobile.Views ImageLoader.cs ThreadPool.QueueUserWorkItem(state => { try { StartPicDownload(uri, target, headers); } catch (Exception e) { Console.WriteLine(e); } }) Link To Source File
NewWestlink LogProcessor.cs ThreadPool.QueueUserWorkItem(_ => { try { T result = function(); tcs.SetResult(result); } catch(Exception exc) { tcs.SetException(exc); } }) Link To Source File
PROMPT11-07-ConcurrentProgramming.sandrapatfer ConcurrentCache.cs ThreadPool.QueueUserWorkItem((o) => { var value = _factory(key); cacheValue.Value = value; }) Link To Source File
PROMPT11-07-ConcurrentProgramming.sandrapatfer AsyncCall.cs ThreadPool.QueueUserWorkItem((o) => { try { result.TResult = func(arg); result.IsCompleted = true; var ev = result.AsyncWaitHandle as ManualResetEvent; ev.Set(); callback(result); } catch (Exception e) { result.ExceptionOut = e; } }) Link To Source File
PROMPT11-07-ConcurrentProgramming.sandrapatfer FileFinderForm.cs ThreadPool.QueueUserWorkItem( (o1)=> { foreach (var dname in Directory.EnumerateDirectories(fldr, "*", SearchOption.AllDirectories)) { if (!_canceled) { itemsCounter.Increment(); ThreadPool.QueueUserWorkItem((o2) => { if (!_canceled) { foreach (var fname in Directory.EnumerateFiles(dname, patt)) { if (_canceled) { break; } String name = fname; Interlocked.Increment(ref _count); String content = File.ReadAllText(name); if (content.Contains(word)) txtResults.AddLine(name); } itemsCounter.Decrement(); } }); } } itemsCounter.Decrement(); }) Link To Source File
PROMPT11-07-ConcurrentProgramming.sandrapatfer FileFinderForm.cs ThreadPool.QueueUserWorkItem((o2) => { if (!_canceled) { foreach (var fname in Directory.EnumerateFiles(dname, patt)) { if (_canceled) { break; } String name = fname; Interlocked.Increment(ref _count); String content = File.ReadAllText(name); if (content.Contains(word)) txtResults.AddLine(name); } itemsCounter.Decrement(); } }) Link To Source File
SimpleConcurrency Schedulers.cs ThreadPool.QueueUserWorkItem(o => action()) Link To Source File
Tag-Cache ScavengedExpirableCacheStore.cs ThreadPool.QueueUserWorkItem(_ScavengeCacheItems) Link To Source File
talifun-commander CommanderManager.cs ThreadPool.QueueUserWorkItem(TheStartup) Link To Source File
twdc ReflectedAsyncActionDescriptor.cs ThreadPool.QueueUserWorkItem(_ => asyncResult.MarkCompleted(false /* completedSynchronously */, asyncCallback)) Link To Source File
twdc AsyncManagerExtensionsTest.cs ThreadPool.QueueUserWorkItem(_ => { callback(asyncResult); waitHandle.Set(); }) Link To Source File
twdc ReflectedAsyncActionDescriptor.cs ThreadPool.QueueUserWorkItem(_ => asyncResult.MarkCompleted(false /* completedSynchronously */, asyncCallback)) Link To Source File
twdc AsyncManagerExtensionsTest.cs ThreadPool.QueueUserWorkItem(_ => { Assert.AreEqual(1, asyncManager.OutstandingOperations.Count, "Counter shouldn't have been decremented yet."); callback(asyncResult); waitHandle.Set(); }) Link To Source File
twdc AsyncManagerExtensionsTest.cs ThreadPool.QueueUserWorkItem(_ => { callback(asyncResult); waitHandle.Set(); }) Link To Source File
twdc ApplicationStartPage.cs ThreadPool.QueueUserWorkItem(new WaitCallback(ShutdownCallBack)) Link To Source File
torshify-server LoginCallbackHandler.cs ThreadPool.QueueUserWorkItem( state => Execute( callback => callback.OnLoggedIn())) Link To Source File
torshify-server LoginCallbackHandler.cs ThreadPool.QueueUserWorkItem( state => Execute( callback => callback.OnLoginError(e.Status.GetMessage()))) Link To Source File
torshify-server LoginCallbackHandler.cs ThreadPool.QueueUserWorkItem( state => Execute( callback => callback.OnLoggedOut())) Link To Source File
torshify-server PlayerCallbackHandler.cs ThreadPool.QueueUserWorkItem( state => Execute( callback => callback.OnTrackComplete(currentTrack))) Link To Source File
torshify-server PlayerCallbackHandler.cs ThreadPool.QueueUserWorkItem( state => Execute(callback => callback.OnTrackChanged(track))) Link To Source File
torshify-server PlayerCallbackHandler.cs ThreadPool.QueueUserWorkItem( state => Execute( callback => callback.OnElapsed(elapsedMs, totalMs))) Link To Source File
torshify-server PlayerCallbackHandler.cs ThreadPool.QueueUserWorkItem( state => Execute( callback => callback.OnPlayStateChanged(isPlaying))) Link To Source File
Medicine-Aggregator MedicinesListViewModel.cs System.Threading.ThreadPool.QueueUserWorkItem(delegate { //DataAccess.CreateMedicinesTestData(89999); MedicinesListView = FetchMedicines(); }) Link To Source File
Medicine-Aggregator MedicinesListViewModel.cs System.Threading.ThreadPool.QueueUserWorkItem(delegate { MedicinesListView = null; MedicinesListView = FetchMedicines(); }) Link To Source File
Medicine-Aggregator AggregationProcessPopupViewModel.cs System.Threading.ThreadPool.QueueUserWorkItem(delegate(object data) { AggregatorService.CancelProcessing(); }) Link To Source File
Medicine-Aggregator AggregationProcessPopupViewModel.cs System.Threading.ThreadPool.QueueUserWorkItem(delegate(object data) { AggregatorService.ProcessFiles(null); }) Link To Source File
vcap-dotnet Agent.cs // toconsider: the pre-starting stage should be able to gracefuly stop when the shutdown flag is set ThreadPool.QueueUserWorkItem(delegate(object data) { this.StartDropletInstance(instance, pmessage.SHA1, pmessage.ExecutableFile, new Uri(pmessage.ExecutableUri)); }) Link To Source File
vcap-dotnet DropletCollection.cs ThreadPool.QueueUserWorkItem(delegate(object data) { this.SnapshotAppState(); this.snapshotScheduled = false; }) Link To Source File
vcap-dotnet DEAUtilities.cs ThreadPool.QueueUserWorkItem(new WaitCallback(delegate(object data) { ProcessStartInfo start = new ProcessStartInfo(); start.FileName = shell; start.Arguments = arguments; start.CreateNoWindow = true; start.UseShellExecute = false; start.RedirectStandardOutput = true; start.RedirectStandardInput = true; string result = string.Empty; using (Process process = Process.Start(start)) { using (StreamWriter writer = process.StandardInput) { writerCallback(writer); } using (StreamReader reader = process.StandardOutput) { result = reader.ReadToEnd(); } process.WaitForExit(); doneCallback(result, process.ExitCode); } })) Link To Source File
EI CommandHandlers.cs ThreadPool.QueueUserWorkItem((obj) => { pvm.Build(); }) Link To Source File
lucene.net TestStringIntern.cs ThreadPool.QueueUserWorkItem(new WaitCallback(threads[i].Run)) Link To Source File
wa-toolkit-games TaskBuilder.cs ThreadPool.QueueUserWorkItem(s => { while (true) { Cycle(); } }) Link To Source File
msgpack-rpc-cli TcpServerTransportManager.cs // Avoid recursive acceptance and the subsequent request delay. // Task is bit heavy here. ThreadPool.QueueUserWorkItem( _ => this.OnAcceptted( context ) ) Link To Source File
msgpack-rpc-cli TcpServerTransportManager.cs // Avoid recursive acceptance and the subsequent request delay. // Task is bit heavy here. ThreadPool.QueueUserWorkItem( _ => this.OnAcceptted( context ) ) Link To Source File