C#线程开发之System.Thread类详解

class Program
{
    static void Main()
    {
        var t1 = new Thread(ThreadMain);
        t1.Start();
        Console.WriteLine("This is the main thread.");
    }
    static void ThreadMain()
    {
        Console.WriteLine("Running in a thread.");
    }
}

static void Main()
{
    var t1 = new Thread(() => Console.WriteLine("running in a thread, id: {0}",Thread.CurrentThread.ManagedThreadId));
    t1.Start();
    Console.WriteLine("This is the main thread, id: {0}",
    Thread.CurrentThread.ManagedThreadId);
}

static void Main()
{
    var d = new Data { Message = "Info" };
    var t2 = new Thread(ThreadMainWithParameters);//ParameterizedThreadStart委托实例
    t2.Start(d);
}
static void ThreadMainWithParameters(object o)//如果使用了 ParameterizedThreadStart委托，线程的入口点必须有一个object类型的参数，且返回类型为void。
{
    Data d = (Data)o;
    Console.WriteLine("Running in a thread, received {0}", d.Message);
}
public struct Data
{
    public string Message;
}

static void Main()
{
    var obj = new MyThread("info");
    var t3 = new Thread(obj.ThreadMain);//实例方法
    t3.Start();
}
//实例方法
public class MyThread
{
    private string data;
    public MyThread(string data)
    {
        this.data = data;
    }
    public void ThreadMain()
    {
        Console.WriteLine("Running in a thread, data: {0}", data);
    }
}

public class Worker
{
    // 此方法将在线程启动时调用。
    public void DoWork()
    {
        while (!_shouldStop)
        {
            Console.WriteLine("工作线程: working...");
        }
        Console.WriteLine("工作线程:正常停止");
    }
    public void RequestStop()
    {
        _shouldStop = true;
    }
    // Volatile用于提示编译器这个数据成员将被多个线程访问。
    private volatile bool _shouldStop;
}

static void Main()
{
    // 创建thread对象,但这不会启动线程。
    Worker workerObject = new Worker();
    Thread workerThread = new Thread(workerObject.DoWork);

    // 启动工作线程。
    workerThread.Start();
    Console.WriteLine("main thread: 启动工作线程...");

    // 循环，直到工作线程激活。
    while (!workerThread.IsAlive) ;

    // 将主线程休眠1毫秒，让工作线程做一些工作:
    Thread.Sleep(1);

    // 请求工作线程停止自身:
    workerObject.RequestStop();//workerObject.Abort()

    //使用Join方法阻塞当前线程，直到工作线程执行完毕才往下执行
    workerThread.Join();
    Console.WriteLine("main thread: 工作线程已经终止.");
}

//定义一个委托实现回调函数 
public delegate void CallBackDelegate(string message);

void Main()
{
    //委托实现方法和定义线程
    CallBackDelegate cbd = CallBack;
    Thread thread = new Thread(initFtpParam);
    thread.Start(cbd);
}

/// <summary>
/// 线程方法
/// </summary>
/// <param name="obj"></param>
public void initFtpParam(object obj)
{
    CallBackDelegate callBackDelegate = obj as CallBackDelegate;
    callBackDelegate("aa");//执行委托
}

/// <summary>
/// 回调方法
/// </summary>
/// <param name="message"></param>
private void CallBack(string message)
{
    Console.Write(message);
}

m.Threading.Thread.CurrentThread.CurrentCulture = new System.Globalization.CultureInfo("en-US");
System.Threading.Thread.CurrentThread.CurrentUICulture = new System.Globalization.CultureInfo("en-US");

System.Globalization.CultureInfo.DefaultThreadCurrentCulture = new System.Globalization.CultureInfo("en-US");
System.Globalization.CultureInfo.DefaultThreadCurrentUICulture = new System.Globalization.CultureInfo("en-US");