using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading;
using System.IO;namespace MultiThreadStore
{class Program{//入口static void Main(string[] args){Goods goods = new Goods();Thread storeGoods = new Thread(new ParameterizedThreadStart(store));Thread sellGoods = new Thread(new ParameterizedThreadStart(sell));storeGoods.Start(goods);sellGoods.Start(goods);Console.ReadLine();}//存货方法private static void store(object obj){bool storeFlag = true;Random random = new Random();while (storeFlag){try{Goods goods = obj as Goods;if (goods.Num < goods.MaxNum){goods.Num++;Console.WriteLine("Store a goods, " + goods.Num + " goods left!");}else {Console.WriteLine("The store is full now.");}Thread.Sleep(random.Next(500, 1000));}catch (Exception ex){WriteLog(ex);storeFlag = false;}}}//卖货方法public static void sell(object obj) {bool sellFlag = true;Random random = new Random();while (sellFlag){try{Goods goods = obj as Goods;if (goods.Num > 0){goods.Num--;Console.WriteLine("Sell a goods, " + goods.Num + " goods left!");}else {Console.WriteLine("There are no goods now.");}Thread.Sleep(random.Next(1000, 4000));}catch (Exception ex){WriteLog(ex);sellFlag = false;}}}//打log方法private static void WriteLog(Exception ex){string logUrl = Environment.GetFolderPath(Environment.SpecialFolder.DesktopDirectory) + "\\MuliThreadStorelog.txt";if (File.Exists(@logUrl)){using (FileStream fs = new FileStream(logUrl, FileMode.Append)){using (StreamWriter sw = new StreamWriter(fs, Encoding.Default)){try{sw.Write(ex);}catch (Exception ex1){WriteLog(ex1);}finally{sw.Close();fs.Close();}}}}else{using (FileStream fs = new FileStream(logUrl, FileMode.CreateNew)){using (StreamWriter sw = new StreamWriter(fs, Encoding.Default)){try{sw.Write(ex);}catch (Exception ex1){WriteLog(ex1);}finally{sw.Close();fs.Close();}}}}}}//货品类class Goods {public int Num { get; set; }public int MaxNum { get; set; }public Goods() {Num = 10;MaxNum = 50;}     }
}