в 15:31, 26 мая 2010

2010-05-26T15:31:35Z

Admin: 1 версия

2010-05-26T12:08:49Z

1 версия

Новая страница

==ThreadPool.QueueUserWorkItem==

<source lang="csharp">
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using System.Reflection;
using System.Reflection.Emit;
public class MainClass
{
public static void Main()
{
ThreadPool.QueueUserWorkItem(delegate {
Console.WriteLine(Assembly.GetCallingAssembly().FullName);
});
Thread.Sleep(100);
}
}

</source>

==ThreadPool.RegisterWaitForSingleObject==

<source lang="csharp">
using System;
using System.Threading;
class MainClass
{
private static void EventHandler(object state, bool timedout)
{
Console.WriteLine("timedout:"+timedout);
Console.WriteLine("state:"+state);
Console.WriteLine(DateTime.Now.ToString("HH:mm:ss.ffff"));
}
public static void Main()
{
AutoResetEvent autoEvent = new AutoResetEvent(false);
string state = "AutoResetEvent signaled.";
RegisteredWaitHandle handle = ThreadPool.RegisterWaitForSingleObject(
autoEvent, EventHandler, state, 3000, false);

Thread.Sleep(5000);

autoEvent.Set();

Console.WriteLine("Unregistering wait operation.");
handle.Unregister(null);
}
}

</source>

==ThreadPool.SetMaxThreads==

<source lang="csharp">
using System;
using System.IO;
using System.Net;
using System.Text;
using System.Threading;
class WebServer {
HttpListener myListener;
string _baseFolder;
public WebServer(string uriPrefix, string baseFolder) {
System.Threading.ThreadPool.SetMaxThreads(50, 1000);
System.Threading.ThreadPool.SetMinThreads(50, 50);
myListener = new HttpListener();
myListener.Prefixes.Add(uriPrefix);
_baseFolder = baseFolder;
}
public void Start() {
myListener.Start();
while (true)
try {
HttpListenerContext request = myListener.GetContext();
ThreadPool.QueueUserWorkItem(ProcessRequest, request);
} catch (HttpListenerException) { break; }
catch (InvalidOperationException) { break; }
}
public void Stop() {
myListener.Stop();
}
void ProcessRequest(object listenerContext) {
try {
var context = (HttpListenerContext)listenerContext;
string filename = Path.GetFileName(context.Request.RawUrl);
string path = Path.rubine(_baseFolder, filename);
byte[] msg;
if (!File.Exists(path)) {
context.Response.StatusCode = (int)HttpStatusCode.NotFound;
msg = Encoding.UTF8.GetBytes("Sorry, that page does not exist");
} else {
context.Response.StatusCode = (int)HttpStatusCode.OK;
msg = File.ReadAllBytes(path);
}
context.Response.ContentLength64 = msg.Length;
using (Stream s = context.Response.OutputStream)
s.Write(msg, 0, msg.Length);
} catch (Exception ex) { Console.WriteLine("Request error: " + ex); }
}
}

</source>

← Предыдущая	Версия 15:31, 26 мая 2010
(нет различий)

Csharp/C Sharp by API/System.Threading/ThreadPool - История изменений

в 15:31, 26 мая 2010

Admin: 1 версия