Project Name File Name Usage Source Code Link
lucene.net TestSimpleFacetedSearch.cs new Thread(MultiThreadedAccessThread) Link To Source File
Agents FixedThreadPoolScheduler.cs new Thread(x => Loop()) Link To Source File
SystemWrapper ThreadWrap.cs new global::System.Threading.Thread(start) Link To Source File
Modl AsyncDbAccess.cs new Thread(WorkManagerLoop) Link To Source File
Modl AsyncWorker.cs new Thread(WorkerLoop) Link To Source File
sable-fx ScriptInterpreter.cs new Thread(AsyncThreadStart) Link To Source File
WCFQuickSamples Program.cs new Thread(new ParameterizedThreadStart(ThreadProc)) Link To Source File
WCFQuickSamples Program.cs new Thread(new ParameterizedThreadStart(ThreadProc)) Link To Source File
WCFQuickSamples Program.cs new Thread(new ParameterizedThreadStart(CallService)) Link To Source File
WCFQuickSamples Program.cs new Thread(CallServiceWithSameProxy) Link To Source File
WCFQuickSamples Program.cs new Thread(CallServiceWithSameProxy) Link To Source File
Lokad.Cloud MemoryBlobStorageProviderTests.cs new Thread(AddValueToContainer) Link To Source File
Lokad.Cloud MemoryTableStorageProviderTests.cs new Thread(CreateTables) Link To Source File
Kinect-Annotation-and-Evaluation-Tool OpenNIRecordingController.cs new Thread(doExport) Link To Source File
Kinect-Annotation-and-Evaluation-Tool OpenNIRecordingController.cs new Thread(onExportFinished) Link To Source File
Orders MouseClickManager.cs new Thread(threadStart) Link To Source File
fubumvc Listener.cs new Thread(o => { Start(runtime, () => { action(); reset.Set(); }); }) Link To Source File
Tempest ConnectionProviderTests.cs new Thread (thread) Link To Source File
SharpDevelop Profiler.cs new Thread(new ParameterizedThreadStart(Logging)) Link To Source File
SharpDevelop CallHelper.cs new Thread(RunWorkbenchInternal) Link To Source File
lokad-cloud-storage MemoryBlobStorageTests.cs new Thread(AddValueToContainer) Link To Source File
DistAppLog AppLogServer.cs new Thread(StartReceiver) Link To Source File
DistAppLog AppLogServer.cs new Thread(new ParameterizedThreadStart(InicioWebserver)) Link To Source File
SuperSocket UdpSocketServer.cs new Thread(StartListen) Link To Source File
SuperSocket IAsyncRunner.cs new Thread(new ParameterizedThreadStart(ExecuteAsyncStart)) Link To Source File
SuperSocket UdpSocketServer.cs new Thread(StartListen) Link To Source File
Schumix2 ServerListener.cs new Thread(new ParameterizedThreadStart(ClientHandler)) Link To Source File
Schumix2 ClientSocket.cs new Thread(new ParameterizedThreadStart(ClientHandler)) Link To Source File
EasyNetQ AckNackSpike.cs new Thread(_ => { var count = 0; while (running && count++ < numberOfMessagesToConsume) { try { var basicDeliverEventArgs = (BasicDeliverEventArgs) consumer.Queue.Dequeue(); if (basicDeliverEventArgs != null) { var message = Encoding.UTF8.GetString(basicDeliverEventArgs.Body); Console.Out.WriteLine("message = {0}", message); Console.WriteLine("Redelivered: {0}", basicDeliverEventArgs.Redelivered); consumer.Model.BasicAck(basicDeliverEventArgs.DeliveryTag, false); // consumer.Model.BasicNack(basicDeliverEventArgs.DeliveryTag, false, requeue:true); } } catch (EndOfStreamException) { break; } } }) Link To Source File
EasyNetQ PingPongSpike.cs new Thread(_ => { while (true) { foreach (var action in Actions) { action(); } } }) Link To Source File
EasyNetQ TaskCompletionSourceSpike.cs new Thread(_ => ProcessItem(itemToProcess)) Link To Source File
monodevelop MainAnalyzer.cs new Thread (DoAnalyze) Link To Source File
monodevelop WebDeployService.cs new Thread (new ParameterizedThreadStart (DoDeploy)) Link To Source File
ClinImIm MockDispatcher.cs new Thread( ignored => { actionToInvoke(); reset.Set(); }) Link To Source File
ClinImIm MockDispatcher.cs new Thread( ignored => { result = actionToInvoke(); reset.Set(); }) Link To Source File
WCFWeb ChannelTests.cs new Thread(BasicChannelTests.SubmitRequests) Link To Source File
WCFWeb ChannelTests.cs new Thread(BasicChannelTests.SubmitRequests) Link To Source File
Paralect.ServiceBus ObservableTest.cs new Thread(_ => { for (int i = 0; i < iterations; i++) { observer.OnNext(i); } observer.OnCompleted(); }) Link To Source File
SSharp Threading.cs new Thread(execute) Link To Source File
memocloud ThreadUtil.cs new Thread(new ParameterizedThreadStart((p) => a(p as T))) Link To Source File
ravendb ColumnValueTests.cs new Thread(this.ThreadProc) Link To Source File
QuickGraph TestCaseWorkerCollection.cs new Thread(new ParameterizedThreadStart(pair.Worker.Start)) Link To Source File
QuickGraph TestRunner.cs new Thread(delegate(object name) { Process.Start(name.ToString()); }) Link To Source File
Picasso Parallel.cs new Thread( new ParameterizedThreadStart( WorkerThread ) ) Link To Source File
Roger Consume_threading.cs new Thread(Publish100Messages) Link To Source File
Roger Consume_threading.cs new Thread(Consume100Messages) Link To Source File
projects HeartbeatTest.cs new Thread(Increment) Link To Source File
sones ScriptInterpreter.cs new Thread(AsyncThreadStart) Link To Source File
NoCap AsynchronousIterator.cs new Thread(_iteratorThread.Iterate) Link To Source File
dwarrowdelf Connection.cs new Thread(DeserializerMain) Link To Source File
dwarrowdelf Program.cs new Thread(KeyMain) Link To Source File
dbcviewer MainForm.EventHandlers.cs new Thread(RunPlugin) Link To Source File
torshify-r4dio GrooveSharkRadioTrackPlayerHandler.cs new Thread(StreamMp3) Link To Source File
vcap-dotnet WcfHttpTunnelParallelTest.cs new Thread(new ParameterizedThreadStart( delegate(object indexObject) { int index = (int)indexObject; using (TcpClient actualClient = new TcpClient()) { actualClient.Connect(IPAddress.Parse("127.0.0.1"), clientPort); using (TcpClient acceptedClient = actualServer.AcceptTcpClient()) { for (int j = 0; j < writeCount; j++) { actualClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(2000); byte[] localReceivedBytes = new byte[1024]; int localReceivedBytesCount = acceptedClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytes[index] = localReceivedBytes; receivedBytesCount[index] = localReceivedBytesCount; } } } )) Link To Source File
vcap-dotnet WcfHttpTunnelParallelTest.cs new Thread(new ParameterizedThreadStart( delegate(object indexObject) { int index = (int)indexObject; using (TcpClient actualClient = new TcpClient()) { actualClient.Connect(IPAddress.Parse("127.0.0.1"), clientPort); // we may not accept the same client that we connected, but the data is the same using (TcpClient acceptedClient = actualServer.AcceptTcpClient()) { byte[] localReceivedBytes; int localReceivedBytesCount; for (int j = 0; j < writeCount; j++) { actualClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(1000); localReceivedBytes = new byte[1024]; localReceivedBytesCount = acceptedClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytesFrom[index] = localReceivedBytes; receivedBytesCountFrom[index] = localReceivedBytesCount; for (int j = 0; j < writeCount; j++) { acceptedClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(1000); localReceivedBytes = new byte[1024]; localReceivedBytesCount = actualClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytesTo[index] = localReceivedBytes; receivedBytesCountTo[index] = localReceivedBytesCount; } } } )) Link To Source File
vcap-dotnet HttpTunnelTest.cs new Thread(new ParameterizedThreadStart( delegate(object indexObject) { int index = (int)indexObject; using (TcpClient actualClient = new TcpClient()) { actualClient.Connect(IPAddress.Parse("127.0.0.1"), clientEndPort); using (TcpClient acceptedClient = actualServer.AcceptTcpClient()) { for (int j = 0; j < writeCount; j++) { actualClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(2000); byte[] localReceivedBytes = new byte[1024]; int localReceivedBytesCount = acceptedClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytes[index] = localReceivedBytes; receivedBytesCount[index] = localReceivedBytesCount; } } } )) Link To Source File
vcap-dotnet HttpTunnelTest.cs new Thread(new ParameterizedThreadStart( delegate(object indexObject) { int index = (int)indexObject; using (TcpClient actualClient = new TcpClient()) { actualClient.Connect(IPAddress.Parse("127.0.0.1"), clientEndPort); // we may not accept the same client that we connected, but the data is the same using (TcpClient acceptedClient = actualServer.AcceptTcpClient()) { byte[] localReceivedBytes; int localReceivedBytesCount; for (int j = 0; j < writeCount; j++) { actualClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(1000); localReceivedBytes = new byte[1024]; localReceivedBytesCount = acceptedClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytesFrom[index] = localReceivedBytes; receivedBytesCountFrom[index] = localReceivedBytesCount; for (int j = 0; j < writeCount; j++) { acceptedClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(1000); localReceivedBytes = new byte[1024]; localReceivedBytesCount = actualClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytesTo[index] = localReceivedBytes; receivedBytesCountTo[index] = localReceivedBytesCount; } } } )) Link To Source File
vcap-dotnet IISPluginTest.cs new Thread(new ParameterizedThreadStart(delegate(object data) { try { IISPlugin target = plugins[(int)data]; target.ConfigureApplication(appInfos[(int)data]); target.StartApplication(); } catch (Exception ex) { Logger.Fatal(ex.ToString()); } })) Link To Source File
vcap-dotnet IISPluginTest.cs new Thread(new ParameterizedThreadStart(delegate(object data) { try { IISPlugin target = plugins[(int)data]; target.StopApplication(); } catch (Exception ex) { Logger.Fatal(ex.ToString()); } })) Link To Source File
vcap-dotnet NatsClientTest.cs new Thread(new ParameterizedThreadStart(delegate(object data) { natsClient.Publish((string)data); })) Link To Source File
vcap-dotnet ClientEnd.cs 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); } })) Link To Source File
vcap-dotnet ClientEnd.cs 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); } })) Link To Source File
vcap-dotnet ClientEnd.cs 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); } })) Link To Source File
vcap-dotnet ClientEnd.cs 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); } })) Link To Source File
lucene.net TestSimpleFacetedSearch.cs new Thread(MultiThreadedAccessThread) Link To Source File