Project Name File Name Usage Source Code Link
lucene.net FilterManager.cs new System.Threading.ThreadStart(filterCleaner.Run) Link To Source File
lucene.net SupportClass.cs new System.Threading.ThreadStart(Run) Link To Source File
lucene.net SupportClass.cs new System.Threading.ThreadStart(Run) Link To Source File
lucene.net TestMultiThreadTermVectors.cs new System.Threading.ThreadStart(this.Run) Link To Source File
starboard-sc2 ScoreboardNetwork.cs new ThreadStart( delegate { while (this.StopListen == false) { var inBuffer = new byte[1000]; EndPoint senderRemote = new IPEndPoint(IPAddress.Any, 0); try { socket.ReceiveFrom(inBuffer, ref senderRemote); } catch (SocketException ex) { int errorCode = ex.ErrorCode; continue; } var packet = ScoreboardPacket.Parse(inBuffer); foreach (var cmd in packet.Commands) { if (cmd.Command == CommandType.Ping) { var pongCmd = new EmptyPacketCommand { Command = CommandType.Pong }; var pongPacket = new ScoreboardPacket() { Commands = new[] { pongCmd } }; socket.SendTo(pongPacket.ToBytes(), senderRemote); } } this.dispatcher.BeginInvoke((Action)(() => sb.HandleRemoteCommands(packet, socket, senderRemote))); } socket.Close(); socket.Dispose(); }) Link To Source File
Kinect MyKinect.cs new ThreadStart(StartKinectThread) Link To Source File
NDistribUnit DomainManager.cs new ThreadStart(UnloadOnThread) Link To Source File
NDistribUnit EventPump.cs new ThreadStart( PumpThreadProc ) Link To Source File
NDistribUnit TestRunnerThread.cs new ThreadStart( TestRunnerThreadProc ) Link To Source File
NDistribUnit TestThread.cs new ThreadStart(RunTestProc) Link To Source File
NDistribUnit EventQueueTests.cs new ThreadStart(this.ConsumerThreadWrapper) Link To Source File
NDistribUnit EventQueueTests.cs new ThreadStart(this.Produce) Link To Source File
NDistribUnit AfterConstraintTests.cs new ThreadStart(MethodSetsValueTrue) Link To Source File
NDistribUnit PNUnitTestRunner.cs new ThreadStart(ThreadProc) Link To Source File
NDistribUnit Runner.cs new ThreadStart(ThreadProc) Link To Source File
NDistribUnit UnhandledExceptions.cs new System.Threading.ThreadStart(Normal) Link To Source File
NDistribUnit UnhandledExceptions.cs new System.Threading.ThreadStart(Normal) Link To Source File
NDistribUnit UnhandledExceptions.cs new System.Threading.ThreadStart(Normal) Link To Source File
NDistribUnit UnhandledExceptions.cs new System.Threading.ThreadStart(ThreadedAssertProc) Link To Source File
BCCL CustomThreadPool.cs new ThreadStart(WorkerThreadLoop) Link To Source File
BCCL ThreadController.cs new ThreadStart(RunTask) Link To Source File
BCCL ThreadController.cs new ThreadStart(RunTask) Link To Source File
BCCL StaticRandomTest.cs new ThreadStart(grabbers[i].GrabNumbers) Link To Source File
BCCL OrderedLockTest.cs new ThreadStart(LockSubject) Link To Source File
BCCL SyncLockTest.cs new ThreadStart(LockSubject) Link To Source File
WCFQuickSamples Program.cs new ThreadStart(delegate { string address = baseAddress + (useGet ? "/Add?x=3&y=9" : "/Echo"); HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(address); req.Method = useGet ? "GET" : "POST"; if (!useGet) { req.ContentType = "application/json"; byte[] reqBody = Encoding.UTF8.GetBytes("/"Hello world/""); Stream reqStream = req.GetRequestStream(); reqStream.Write(reqBody, 0, reqBody.Length); reqStream.Close(); } HttpWebResponse resp; try { resp = (HttpWebResponse)req.GetResponse(); } catch (WebException ex) { resp = ex.Response as HttpWebResponse; } if (resp == null) { Console.WriteLine("Response is null"); } else { Console.WriteLine("HTTP/{0} {1} {2}", resp.ProtocolVersion, (int)resp.StatusCode, resp.StatusDescription); resp.Close(); } }) Link To Source File
WCFQuickSamples Program.cs new ThreadStart(StartServer) Link To Source File
babelim AmipNowPlayingListerner.cs new ThreadStart(Listen) Link To Source File
babelim ChatViewManager.cs new ThreadStart ( delegate { lock (SyncObject) { if (!activate) { ChatViewModel viewModel = new ChatViewModel(chat); ChatView view = new ChatView(); view.DataContext = viewModel; PivotItem chatViewItem = new PivotItem(); chatViewItem.HorizontalAlignment = HorizontalAlignment.Stretch; chatViewItem.HorizontalContentAlignment = HorizontalAlignment.Stretch; chatViewItem.Header = chat.Contact.DisplayName; chatViewItem.Content = view; this.chatViews.Add(chat.Contact.ContactId.BareIdentifier, chatViewItem); this.container.Items.Add(chatViewItem); this.container.Invalidate(); this.container.SelectedItem = chatViewItem; } else { this.container.SelectedItem = this.chatViews[chat.Contact.ContactId.BareIdentifier]; } } } ) Link To Source File
babelim LayoutView.xaml.cs new ThreadStart ( delegate { switch (newState) { case XmppSessionState.LoggedIn: VisualStateManager.GoToState(this, "LoggedIn", true); break; case XmppSessionState.LoggingIn: VisualStateManager.GoToState(this, "LoggingIn", false); break; case XmppSessionState.LoggingOut: VisualStateManager.GoToState(this, "LoggingOut", true); break; case XmppSessionState.Error: VisualStateManager.GoToState(this, "Error", true); break; } } ) Link To Source File
babelim Shell.xaml.cs new ThreadStart ( delegate { WindowInteropHelper helper = new WindowInteropHelper(this); if (!this.IsVisible) { this.ShowActivated = false; this.Visibility = Visibility.Visible; } if (!this.IsActive || this.WindowState == WindowState.Minimized) { Win32NativeMethods.FlashWindow(helper.Handle); } } ) Link To Source File
babelim SessionViewModel.cs new ThreadStart(delegate { // Update the configuration this.currentAccount.Avatar = hash; // Save configuration ServiceFactory.Current.Resolve().Configuration.Save(); // Notify avatar change this.NotifyPropertyChanged(() => AvatarImage); }) Link To Source File
babelim SessionView.xaml.cs new ThreadStart ( delegate { CollectionViewSource viewSource = this.Resources["ContactsViewSource"] as CollectionViewSource; viewSource.View.Refresh(); } ) Link To Source File
Castle.Windsor-READONLY DispatcherObjectTestCase.cs new ThreadStart(delegate { }) Link To Source File
Castle.Windsor-READONLY DispatcherObjectTestCase.cs new ThreadStart(() => thread.Start()) Link To Source File
Windsor DispatcherObjectTestCase.cs new ThreadStart(delegate { }) Link To Source File
Windsor DispatcherObjectTestCase.cs new ThreadStart(() => thread.Start()) Link To Source File
c-raft RegionFile.cs new ThreadStart(() => { int sector = 0; lock (sectors) for (int i = 0; i < 1024; i++) { sector = EndiannessConverter.ToInt32(sectors[i]); region.offsets[i] = new McrOffset() { SectorSize = (byte)(sector & 0xFF), SectorOffset = sector >> 8, }; } sectors = null; }) Link To Source File
c-raft RegionFile.cs new ThreadStart(() => { #if DEBUG DateTime start = DateTime.Now; #endif int offset = index * (1024 / MaxTHREADS); MemoryStream mmStream = null; for (int n = 0; n < chunkWorkerBuffer.Length; n++) { byte[] chunk = chunkWorkerBuffer[n]; if (chunk == null) continue; mmStream = new MemoryStream(chunk); region.chunks[n + offset] = NBTFile.OpenFile(mmStream, 2); mmStream.Dispose(); } chunkWorkerBuffer = null; #if DEBUG Console.WriteLine("Thread worker " + (index + 1) + " is complete! Took " + (int)(DateTime.Now - start).TotalMilliseconds + "ms to process."); }) Link To Source File
EasyNMS NmsConnectionPool.cs new ThreadStart(this.InnerStart) Link To Source File
EasyNMS NmsConnectionPool.cs new ThreadStart(this.InnerStart) Link To Source File
EasyNMS NmsConnectionPool.cs new ThreadStart(this.InnerStart) Link To Source File
EasyNMS NmsConnectionPool.cs new ThreadStart(this.VoidNewConnection) Link To Source File
EasyNMS NmsConnectionPool.cs new ThreadStart(this.VoidNewConnection) Link To Source File
Plywood PlywoodPullService.cs new System.Threading.ThreadStart(ThreadProc) Link To Source File
localtunnel-net-client TestServer.cs new ThreadStart(ServerTestThreadProc) Link To Source File
localtunnel-net-client TestServer.cs new ThreadStart(ClientTestThreadProc) Link To Source File
fubumvc JasmineRunner.cs new ThreadStart(run) Link To Source File
MaximusParserX frmSniffList.cs new System.Threading.ThreadStart(UpdateViewerInternal) Link To Source File
sbc Form1.cs new ThreadStart(t.work) Link To Source File
sbc Program.cs new ThreadStart(() => { _client.NotifyNestVerschickt(nest); Work(); }) Link To Source File
sbc Program.cs new ThreadStart(() => { _client.AddBemaltesEi(ei); Work(); }) Link To Source File
sbc Program.cs new ThreadStart(() => { _client.AddNest(nest); Work(); }) Link To Source File
evemu_incursion AttributesOptimizationForm.cs new ThreadStart(Run) Link To Source File
evemu_incursion TreeView.cs new ThreadStart(FlashNode) Link To Source File
evemu_incursion TreeView.cs new ThreadStart(StartEdit) Link To Source File
ForgeCraft-OutDatedVersion CmdFlat.cs new ThreadStart(() => Cuboid(p, width, length, height, block)) Link To Source File
ForgeCraft-OutDatedVersion Chunker.cs new ThreadStart(delegate { try { Parallel.For(0, Server.genThreads, delegate(int wtf) // The int is so the compiler will shut up. { GeneratorLoop(); }); } catch (NotImplementedException) { Logger.Log("Parallel.For() is not implemented, chunk generation will be single-threaded."); GeneratorLoop(); } }) Link To Source File
ForgeCraft-OutDatedVersion Chunker.cs new ThreadStart(delegate { while (!Server.s.shuttingDown) { try { if (loadQueue.Count < 1) { Thread.Sleep(100); continue; } loadQueue.ForEach(delegate(ChunkLoadQueue clq) { if (clq.unload) { if (clq.world.chunkData.ContainsKey(new Point(clq.x, clq.z))) clq.world.UnloadChunk(clq.x, clq.z); } else { if (!clq.world.chunkData.ContainsKey(new Point(clq.x, clq.z))) clq.world.LoadChunk(clq.x, clq.z, true, false); } Thread.Sleep(5); }); loadQueue.Clear(); } catch { } } }) Link To Source File
ForgeCraft-OutDatedVersion Chunker.cs new ThreadStart(delegate { Point pt; while (!Server.s.shuttingDown) { try { if (sendQueue.Count < 1) { Thread.Sleep(100); continue; } sendQueue.ForEach(delegate(ChunkSendQueue csq) { pt = new Point(csq.x, csq.z); if (!csq.player.LoggedIn || (DateTime.Now - csq.time).TotalSeconds >= 60) { csq.sent = true; return; } if (csq.player.level.chunkData.ContainsKey(pt) && csq.player.level.chunkData[pt].generated) { //Console.WriteLine("SENT " + csq.x + "," + csq.z); csq.player.SendChunk(csq.player.level.chunkData[pt]); //csq.player.level.chunkData[pt].Update(csq.player.level, csq.player); csq.sent = true; } Thread.Sleep(5); }); sendQueue.RemoveAll(csq => csq.sent); } catch { } } }) Link To Source File
ForgeCraft-OutDatedVersion DeveloperTools.cs new ThreadStart( delegate { using (var web = new WebClient()) { try { response = web.DownloadString(siteName); } catch (WebException) { throw new WebException(); } } if (String.IsNullOrWhiteSpace(response)) throw new Exception("Website Returned No Information"); lines = response.Split('/n'); if (lineNumber >= lines.Count()) throw new Exception( "Line number exceeds number of lines in website"); //maybe add callback feature? }) Link To Source File
ForgeCraft-OutDatedVersion DeveloperTools.cs new ThreadStart( delegate { using (var web = new WebClient()) { try { response = web.DownloadString(siteName); } catch (WebException) { throw new WebException(); } } if (String.IsNullOrWhiteSpace(response)) throw new Exception("Website Returned No Information"); }) Link To Source File
ForgeCraft-OutDatedVersion Program.cs new ThreadStart(InventoryDebug) Link To Source File
ForgeCraft-OutDatedVersion Physics.cs new ThreadStart(RunLoop) Link To Source File
ForgeCraft-OutDatedVersion World.cs new System.Threading.ThreadStart(delegate { int speed = 50, wait = speed; while (!Server.s.shuttingDown) { try { if (!timerunning) { System.Threading.Thread.Sleep(speed); continue; } if (wait > 0) System.Threading.Thread.Sleep(wait); DateTime Start = DateTime.Now; time++; if (time > 24000) { time = 0; moonPhase++; if (moonPhase > 7) moonPhase = 0; } if (TimeChanged != null) TimeChanged(); if (WorldTimeChanged != null) WorldTimeChanged(); TimeSpan Took = DateTime.Now - Start; wait = speed - (int)Took.TotalMilliseconds; } catch { wait = speed; } } }) Link To Source File
ForgeCraft-OutDatedVersion Server.cs new ThreadStart(UpdateDevs) Link To Source File
ForgeCraft-OutDatedVersion Server.cs new ThreadStart(delegate { int wait = 0, speed = 50; while (!Server.s.shuttingDown) { try { if (wait > 0) Thread.Sleep(wait); DateTime Start = DateTime.Now; Entity.EntityPhysics(); TimeSpan Took = DateTime.Now - Start; wait = speed - (int)Took.TotalMilliseconds; } catch { wait = speed; } } }) Link To Source File
ForgeCraft-OutDatedVersion Player.cs new ThreadStart(() => Poison(timespan, interval, true)) Link To Source File
ForgeCraft-OutDatedVersion CmdCheckPort.cs new ThreadStart(delegate { try { using (WebClient WEB = new WebClient()) { response = WEB.DownloadString("http://www.mcforge.net/ports.php?port=" + port); } if (response == "open") { if (!p.IsConsole) p.SendMessage(Color.Green + "Port Open!"); else Logger.Log("Port Open!"); return; } if (response == "closed") { if (!p.IsConsole) p.SendMessage(Color.Red + "Port Closed"); else Logger.Log("Port Closed"); return; } if (!p.IsConsole) p.SendMessage(Color.Yellow + "An Error has occured"); else Logger.Log("An Error has occured"); return; } catch { if (!p.IsConsole) p.SendMessage(Color.Yellow + "An Error has occured"); else Logger.Log("An Error has occured"); return; } }) Link To Source File
PugRanking IrcConnection.cs new ThreadStart(_Worker) Link To Source File
PugRanking IrcConnection.cs new ThreadStart(_Worker) Link To Source File
PugRanking IrcConnection.cs new ThreadStart(_Worker) Link To Source File
ILSpy OpenFromGacDialog.xaml.cs new ThreadStart(FetchGacContents) Link To Source File
ILSpy DecompilerTextView.cs new ThreadStart( delegate { #if DEBUG if (System.Diagnostics.Debugger.IsAttached) { try { AvalonEditTextOutput textOutput = new AvalonEditTextOutput(); textOutput.LengthLimit = outputLengthLimit; DecompileNodes(context, textOutput); textOutput.PrepareDocument(); tcs.SetResult(textOutput); } catch (AggregateException ex) { tcs.SetException(ex); } catch (OperationCanceledException ex) { tcs.SetException(ex); } } else #endif { try { AvalonEditTextOutput textOutput = new AvalonEditTextOutput(); textOutput.LengthLimit = outputLengthLimit; DecompileNodes(context, textOutput); textOutput.PrepareDocument(); tcs.SetResult(textOutput); } catch (Exception ex) { tcs.SetException(ex); } } }) Link To Source File
ILSpy DecompilerTextView.cs new ThreadStart( delegate { try { Stopwatch stopwatch = new Stopwatch(); stopwatch.Start(); using (StreamWriter w = new StreamWriter(fileName)) { try { DecompileNodes(context, new PlainTextOutput(w)); } catch (OperationCanceledException) { w.WriteLine(); w.WriteLine("Decompiled was cancelled."); throw; } } stopwatch.Stop(); AvalonEditTextOutput output = new AvalonEditTextOutput(); output.WriteLine("Decompilation complete in " + stopwatch.Elapsed.TotalSeconds.ToString("F1") + " seconds."); output.WriteLine(); output.AddButton(null, "Open Explorer", delegate { Process.Start("explorer", "/select,/"" + fileName + "/""); }); output.WriteLine(); tcs.SetResult(output); #if DEBUG } catch (OperationCanceledException ex) { tcs.SetException(ex); } catch (AggregateException ex) { tcs.SetException(ex); #else } catch (Exception ex) { tcs.SetException(ex); #endif } }) Link To Source File
SharpDevelop ObjectCreator.cs new ThreadStart(EntryRun) Link To Source File
SharpDevelop Profiler.cs new ThreadStart(DataCollection) Link To Source File
SharpDevelop Form1.cs new ThreadStart(MyThread) Link To Source File
SharpDevelop ConnectionWizardWindow.xaml.cs new ThreadStart( delegate() { try { if (SelectedDatabaseDriver != null) { SetIsLoading(true); SelectedDatabaseDriver.PopulateDatasources(); } } catch (Exception ex) { Dispatcher.BeginInvoke(DispatcherPriority.Background, new Action(() => { MessageBox.Show(this, ex.Message, this.Title, MessageBoxButton.OK, MessageBoxImage.Error); })); } finally { SetIsLoading(false); } } ) Link To Source File
SharpDevelop ConnectionWizardWindow.xaml.cs new ThreadStart( delegate() { if (SelectedDatabaseDriver != null) { SetIsLoading(true); try { SelectedDatabaseDriver.PopulateDatabases(_selectedDatasource); } catch (Exception ex) { Dispatcher.BeginInvoke(DispatcherPriority.Background, new Action(() => { MessageBox.Show(this, ex.Message, this.Title, MessageBoxButton.OK, MessageBoxImage.Error); })); } SetIsLoading(false); } }) Link To Source File
SharpDevelop HistoryViewPanel.cs new ThreadStart(GetLogMessages) Link To Source File
SharpDevelop DockablePane.cs new ThreadStart(delegate { OpenOptionsMenu(null); }) Link To Source File
SharpDevelop ManagedContent.cs new ThreadStart(delegate { ContainerPane.OpenOptionsMenu(null); }) Link To Source File
SharpDevelop ManagedContent.cs new ThreadStart(delegate { if (IsActiveContent && !IsKeyboardFocused) { if (DefaultElement != null) { Debug.WriteLine("Try to set kb focus to " + DefaultElement); IInputElement kbFocused = Keyboard.Focus(DefaultElement); if (kbFocused != null) Debug.WriteLine("Focused element " + kbFocused); else Debug.WriteLine("No focused element"); } else if (Content is UIElement && Content is DependencyObject) { Debug.WriteLine("Try to set kb focus to " + this.Content.ToString()); (Content as UIElement).Focus(); IInputElement kbFocused = Keyboard.Focus(this.Content as IInputElement); if (kbFocused != null) Debug.WriteLine("Focused element " + kbFocused); else Debug.WriteLine("No focused element"); } } }) Link To Source File
SharpDevelop LoadSolutionProjects.cs new ThreadStart(RunThread) Link To Source File
MotionFx HandPointGenerator.cs new ThreadStart(DoGeneratePointsWorker) Link To Source File
Craig-s-Utility-Library WebPageThumbnail.cs new ThreadStart(CreateBrowser) Link To Source File
Craig-s-Utility-Library WebPageThumbnail.cs new ThreadStart(CreateBrowser) Link To Source File
Fracture ParallelThreadPool.cs new ThreadStart(this.ThreadFunc) Link To Source File
Wheezy.Pivot ITunesRemote.cs new ThreadStart(connectAsync) Link To Source File
SIinformer InfoUpdater.cs new ThreadStart(delegate { }) Link To Source File
SIinformer ImportWindow.xaml.cs new ThreadStart(delegate { }) Link To Source File
SIinformer ImportWindow.xaml.cs new ThreadStart(delegate { }) Link To Source File
SuperSocket UdpSocketServerTest.cs new ThreadStart(() => { Console.WriteLine("C: " + m_Encoding.GetString(ReceiveMessage(trySocket, serverAddress).ToArray())); }) Link To Source File
SuperSocket UdpSocketServerTest.cs new ThreadStart(() => { Console.WriteLine("C: " + m_Encoding.GetString(ReceiveMessage(trySocket, serverAddress).ToArray())); }) Link To Source File
ForgeCraft Program.cs new ThreadStart(receive) Link To Source File
ForgeCraft Server.cs new ThreadStart(p.Start) Link To Source File
LunchCrawler LunchRestaurantAnalyzer.cs new ThreadStart(AnalyzeLunchRestaurants) Link To Source File
LunchCrawler LunchRestaurantSeeker.cs new ThreadStart(SeekLunchRestaurants) Link To Source File
monodevelop Debugger.cs new System.Threading.ThreadStart(Win32NativeEvent.Dispatch) Link To Source File
monodevelop Connection.cs new ThreadStart (receiver_thread_main) Link To Source File
monodevelop Thread.cs new ThreadStart (InternalRun) Link To Source File
monodevelop NUnitService.cs new ThreadStart (RunTests) Link To Source File
monodevelop NUnitAssemblyTestSuite.cs new ThreadStart (RunAsyncLoadTest) Link To Source File
monodevelop ProcessWrapper.cs new ThreadStart(CaptureOutput) Link To Source File
monodevelop ProcessWrapper.cs new ThreadStart(CaptureError) Link To Source File
monodevelop TargetRuntime.cs new ThreadStart (BackgroundInitialize) Link To Source File
monodevelop ProjectDomService.cs new ThreadStart(ParserUpdateThread) Link To Source File
monodevelop ClassBrowserPadWidget.cs new ThreadStart (SearchThread) Link To Source File
monodevelop DispatchService.cs new ThreadStart (backgroundDispatcher) Link To Source File
monodevelop DispatchService.cs new ThreadStart (smc.Run) Link To Source File
monodevelop DispatchService.cs new ThreadStart (smc.Run) Link To Source File
TwitterStudio DialogboxPurger.cs new ThreadStart(this.HandleDialogBoxes) Link To Source File
bbwifimusicsync KayakServer.cs new ThreadStart(Start) Link To Source File
bbwifimusicsync OarsServer.cs new ThreadStart(Dispatch) Link To Source File
WCFWeb JObjectFunctionalTest.cs new ThreadStart(delegate { for (int j = 0; j < 10; j++) { try { string str = jo.ToString(); if (str != expected) { incorrectValue = true; Log.Info("Value is incorrect"); } } catch (Exception e) { exceptionThrown = true; Log.Info("Exception thrown: {0}", e); } } }) Link To Source File
CodingDojoHelper DialogboxPurger.cs new ThreadStart(this.HandleDialogBoxes) Link To Source File
Log2Console DebugMonitor.cs new ThreadStart(Capture) Link To Source File
memocloud ThreadUtil.cs new ThreadStart(() => a()) Link To Source File
Floe DccOperation.cs new ThreadStart(() => { var ar = _listener.BeginAcceptTcpClient(null, null); int index = WaitHandle.WaitAny(new[] { ar.AsyncWaitHandle, _endHandle }, ListenTimeout); switch (index) { case 0: try { _tcpClient = _listener.EndAcceptTcpClient((IAsyncResult)ar); } catch (SocketException) { break; } finally { _listener.Stop(); } var endpoint = (IPEndPoint)_tcpClient.Client.RemoteEndPoint; this.Address = endpoint.Address; this.Port = endpoint.Port; this.OnConnected(); try { this.SocketLoop(); } catch (Exception ex) { this.OnError(ex); } break; case 1: _listener.Stop(); break; case WaitHandle.WaitTimeout: _listener.Stop(); this.OnError(new TimeoutException()); break; } }) Link To Source File
Floe DccOperation.cs new ThreadStart(() => { var ar = _tcpClient.BeginConnect(address, port, null, null); if (ar.AsyncWaitHandle.WaitOne(ConnectTimeout)) { try { _tcpClient.EndConnect(ar); this.OnConnected(); } catch (SocketException ex) { this.OnError(ex); return; } catch (NullReferenceException) { return; } try { this.SocketLoop(); } catch(Exception ex) { this.OnError(ex); } } else { this.OnError(new TimeoutException()); } }) Link To Source File
Floe IrcConnection.cs new ThreadStart(this.SocketMain) Link To Source File
Floe RtpClient.cs new ThreadStart(ThreadProc) Link To Source File
QuickGraph FixtureRunner.cs new ThreadStart(worker.RunAsync) Link To Source File
QuickGraph TestRunner.cs new ThreadStart(this.OpenReport) Link To Source File
Picasso MainForm.cs new ThreadStart( MoveCycle ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( QLearningThread ) Link To Source File
Picasso MainForm.cs new ThreadStart( SarsaThread ) Link To Source File
Picasso MainForm.cs new ThreadStart( ShowSolutionThread ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso MainForm.cs new ThreadStart( SearchSolution ) Link To Source File
Picasso StereoViewForm.cs new ThreadStart( stereoThread ) Link To Source File
Picasso SRV1.cs new ThreadStart( CommunicationThread ) Link To Source File
Picasso SRV1Camera.cs new ThreadStart( WorkerThread ) Link To Source File
Picasso Qwerk.Video.cs new ThreadStart( WorkerThread ) Link To Source File
Picasso AsyncVideoSource.cs new ThreadStart( imageProcessingThread_Worker ) Link To Source File
Picasso JPEGStream.cs new ThreadStart( WorkerThread ) Link To Source File
Picasso MJPEGStream.cs new ThreadStart( WorkerThread ) Link To Source File
Picasso FileVideoSource.cs new ThreadStart( WorkerThread ) Link To Source File
Picasso VideoCaptureDevice.cs new ThreadStart( WorkerThread ) Link To Source File
Picasso AVIFileVideoSource.cs new ThreadStart( WorkerThread ) Link To Source File
Picasso XimeaVideoSource.cs new ThreadStart( WorkerThread ) Link To Source File
sones ThreadPool.cs new ThreadStart(Worker) Link To Source File
sones TCPSocketListener.cs new ThreadStart(Run) Link To Source File
sones UDPSocketMulticast.cs new ThreadStart(Run) Link To Source File
sones DrainPipeLog.cs new ThreadStart(WriteThreadInstance.Run) Link To Source File
sones UDC_Client.cs new ThreadStart(UDCClientThreadInstance.Run) Link To Source File
csharputils Util.cs new ThreadStart(runnable.run) Link To Source File
spring-net-amqp Program.cs new ThreadStart(marketDataService.SendMarketData) Link To Source File
hoehoe2 AppendSettingDialog.cs new ThreadStart(() => { tw.GetInfoApi(null); if (IsHandleCreated && !IsDisposed) { Invoke(new MethodInvoker(DisplayApiMaxCount)); } }) Link To Source File
mbta Runnable.cs new ThreadStart(Run) Link To Source File
alaris DccChatSession.cs new ThreadStart( session.Listen ) Link To Source File
vcap-dotnet CloudTestAppParallelTest.cs new ThreadStart(delegate { try { PushApp(name, cloudTestAppDir, url); } catch (Exception ex) { lock (lck) { exceptions.Add(ex); } } }) Link To Source File
vcap-dotnet CloudTestAppParallelTest.cs new ThreadStart(delegate { try { client.DeleteApp(name); } catch (Exception ex) { lock (lck) { exceptions.Add(ex); } } }) Link To Source File
vcap-dotnet CloudTestAppParallelTest.cs new ThreadStart(delegate { try { PushApp(name, cloudTestAppDir, url); } catch (Exception ex) { lock (lck) { exceptions.Add(ex); } } }) Link To Source File
vcap-dotnet CloudTestAppParallelTest.cs new ThreadStart(delegate { try { client.DeleteApp(name); } catch (Exception ex) { lock (lck) { exceptions.Add(ex); } } }) Link To Source File
vcap-dotnet CloudTestAppTest.cs new ThreadStart(delegate { try { PushApp(name, cloudTestAppDir, url); } catch (Exception ex) { lock (lck) { exceptions.Add(ex); } } }) Link To Source File
vcap-dotnet CloudTestAppTest.cs new ThreadStart(delegate { try { client.DeleteApp(name); } catch (Exception ex) { lock (lck) { exceptions.Add(ex); } } }) Link To Source File
vcap-dotnet ClientEnd.cs new ThreadStart( delegate { using (ChannelFactory channelFactory = new ChannelFactory(new BasicHttpBinding(), endpointAddress)) { ITunnel wcfTunnelChannel = channelFactory.CreateChannel(endpointAddress); while (!this.closing) { TcpClient acceptedClient = listener.AcceptTcpClient(); Guid serverConnectionId = Guid.Empty; try { serverConnectionId = wcfTunnelChannel.OpenConnection(); } catch (CommunicationException ex) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotOpenConnection, ex.ToString()); return; } clients[serverConnectionId] = acceptedClient; System.Threading.Thread threadReader = new System.Threading.Thread( new System.Threading.ParameterizedThreadStart(delegate(object objConnectionId) { Guid connectionId = (Guid)objConnectionId; TcpClient client = clients[connectionId]; while (!this.closing) { byte[] buffer = new byte[DataPackage.BufferSize]; int readCount = 0; try { readCount = client.GetStream().Read(buffer, 0, buffer.Length); } catch (IOException ex) { SocketException socketException = ex.InnerException as SocketException; // the 10054 means connection reset by peer if (socketException != null && socketException.ErrorCode == 10054) { client.Close(); try { wcfTunnelChannel.CloseConnection(connectionId); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotCloseConnection, comEx.ToString()); return; } break; } else { throw; } } if (readCount == 0) { client.Close(); try { wcfTunnelChannel.CloseConnection(connectionId); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotCloseConnection, comEx.ToString()); return; } break; } byte[] sendData = new byte[readCount]; Array.Copy(buffer, sendData, readCount); DataPackage sendDataPackage = new DataPackage(); sendDataPackage.Data = sendData; sendDataPackage.HasData = true; DataPackage receiveData = null; try { receiveData = wcfTunnelChannel.SendData(connectionId, sendDataPackage); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotSendData, comEx.ToString()); return; } if (receiveData.HasData) { client.GetStream().Write(receiveData.Data, 0, receiveData.Data.Length); } Thread.Sleep(DataPackage.PollInterval); } })); threadReader.IsBackground = true; this.connectionThreads.Add(threadReader); threadReader.Start(serverConnectionId); System.Threading.Thread threadWriter = new System.Threading.Thread( new System.Threading.ParameterizedThreadStart(delegate(object objConnectionId) { Guid connectionId = (Guid)objConnectionId; TcpClient client = clients[connectionId]; while (!this.closing && client.Connected) { DataPackage data = null; try { data = wcfTunnelChannel.ReceiveData(connectionId); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotReceiveData, comEx.ToString()); return; } if (data.HasData) { if (client != null) { client.GetStream().Write(data.Data, 0, data.Data.Length); } } Thread.Sleep(DataPackage.PollInterval); } })); threadWriter.IsBackground = true; this.connectionThreads.Add(threadWriter); threadWriter.Start(serverConnectionId); } } }) Link To Source File
vcap-dotnet ClientEnd.cs new ThreadStart( delegate { using (ChannelFactory channelFactory = new ChannelFactory(new BasicHttpBinding(), endpointAddress)) { ITunnel wcfTunnelChannel = channelFactory.CreateChannel(endpointAddress); Guid serverConnectionId = Guid.Empty; try { serverConnectionId = wcfTunnelChannel.OpenConnection(); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotOpenConnection, comEx.ToString()); return; } System.Threading.Thread threadReader = new System.Threading.Thread( new System.Threading.ParameterizedThreadStart(delegate(object objConnectionId) { Guid connectionId = (Guid)objConnectionId; while (!this.closing) { byte[] buffer; IPEndPoint remoteEndPoint = new IPEndPoint(IPAddress.Any, localPort); buffer = listener.Receive(ref remoteEndPoint); DataPackage sendDataPackage = new DataPackage(); sendDataPackage.Data = buffer; sendDataPackage.HasData = true; try { wcfTunnelChannel.SendData(connectionId, sendDataPackage); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotSendData, comEx.ToString()); return; } Thread.Sleep(DataPackage.PollInterval); } })); threadReader.IsBackground = true; this.connectionThreads.Add(threadReader); if (listening) { threadReader.Start(serverConnectionId); } System.Threading.Thread threadWriter = new System.Threading.Thread( new System.Threading.ParameterizedThreadStart(delegate(object objConnectionId) { Guid connectionId = (Guid)objConnectionId; while (!this.closing) { DataPackage data = null; try { data = wcfTunnelChannel.ReceiveData(connectionId); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotReceiveData, comEx.ToString()); return; } if (data.HasData) { if (listener != null) { listener.Send(data.Data, data.Data.Length); } } Thread.Sleep(DataPackage.PollInterval); } })); threadWriter.IsBackground = true; this.connectionThreads.Add(threadWriter); if (!listening) { threadWriter.Start(serverConnectionId); } while (!this.closing) { Thread.Sleep(100); } } }) Link To Source File
Xtal DataStore.cs new ThreadStart(workerMethod) Link To Source File
lucene.net FilterManager.cs new System.Threading.ThreadStart(filterCleaner.Run) Link To Source File
lucene.net SupportClass.cs new System.Threading.ThreadStart(Run) Link To Source File
lucene.net SupportClass.cs new System.Threading.ThreadStart(Run) Link To Source File
lucene.net TestMultiThreadTermVectors.cs new System.Threading.ThreadStart(this.Run) Link To Source File
Terraria-Map-Generator MapGeneratorForm.cs new ThreadStart(GenerateWorker) Link To Source File