急 c# 多线程 访问一个变量 30
有许多线程共同访问一个变量只允许一个进程进入访问其他进程等待,等到一个时候我可以通过程序控制,然后其他进程再进入一个进行访问,其余那些没访问过的继续等待,请问这个怎么实现...
有许多线程共同访问一个变量 只允许一个进程进入访问其他进程等待, 等到一个时候我可以通过程序控制,然后其他进程再进入一个进行访问,其余那些没访问过的继续等待,请问这个怎么实现 急~~~~~~ 最好有例子的
展开
2个回答
展开全部
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
namespace threadstop
{
class Program
{
static int methodNumber = 1000;
public IList<string> list = new List<string>();
static ManualResetEvent manu = new ManualResetEvent(false);
static void Main(string[] args)
{
Program p = new Program();
p.run();
}
public void run()
{
for (int i = 0; i < 1000; i++)
{
ThreadPool.QueueUserWorkItem(new WaitCallback(TestMethod), i);
}
manu.WaitOne();
Console.WriteLine("finish");
Console.WriteLine(this.list.Count);
Console.Read();
}
public void TestMethod(object state)
{
try
{
for (int i = 0; i < 10000; i++)
{
lock (list)
{
list.Add(i.ToString());
}
}
}
finally
{
if (Interlocked.Decrement(ref methodNumber) == 0)
manu.Set();
}
}
}
//public class Program
//{
// public IList<string> list = new List<string>();
// public void Method()
// {
// for (int i = 0; i < 1000; i++)
// {
// lock (list)
// {
// list.Add(i.ToString());
// }
// }
// }
// public void dosomething()
// {
// for (int i = 0; i < 100; i++)
// {
// Thread thread = new Thread(Method);
// thread.Start();
// }
// }
// static void Main(string[] args)
// {
// Program p= new Program();
// p.dosomething();
// Console.WriteLine(p.list.Count);
// Console.Read();
// }
//}
}
-----------------------------关键代码---------------------------------
lock (list)
{
list.Add(i.ToString());
}
using System.Collections.Generic;
using System.Text;
using System.Threading;
namespace threadstop
{
class Program
{
static int methodNumber = 1000;
public IList<string> list = new List<string>();
static ManualResetEvent manu = new ManualResetEvent(false);
static void Main(string[] args)
{
Program p = new Program();
p.run();
}
public void run()
{
for (int i = 0; i < 1000; i++)
{
ThreadPool.QueueUserWorkItem(new WaitCallback(TestMethod), i);
}
manu.WaitOne();
Console.WriteLine("finish");
Console.WriteLine(this.list.Count);
Console.Read();
}
public void TestMethod(object state)
{
try
{
for (int i = 0; i < 10000; i++)
{
lock (list)
{
list.Add(i.ToString());
}
}
}
finally
{
if (Interlocked.Decrement(ref methodNumber) == 0)
manu.Set();
}
}
}
//public class Program
//{
// public IList<string> list = new List<string>();
// public void Method()
// {
// for (int i = 0; i < 1000; i++)
// {
// lock (list)
// {
// list.Add(i.ToString());
// }
// }
// }
// public void dosomething()
// {
// for (int i = 0; i < 100; i++)
// {
// Thread thread = new Thread(Method);
// thread.Start();
// }
// }
// static void Main(string[] args)
// {
// Program p= new Program();
// p.dosomething();
// Console.WriteLine(p.list.Count);
// Console.Read();
// }
//}
}
-----------------------------关键代码---------------------------------
lock (list)
{
list.Add(i.ToString());
}
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询