java 多线程操作hashtable(添加，删除，遍历)

Posted 2023-03-22

程序启动以后,开3个线程, 同时操作同一个hashtable. 一个负责随机添加数据, 另一个负责删除数据, 还有一个对hashtable进行遍历.

public class TestThread
public static void main(String[] args)
Map<Integer, Object> tables = new Hashtable<Integer, Object>();
Thread add = new Thread(new ThreadAdd(tables));
Thread del = new Thread(new ThreadDel(tables));
Thread count = new Thread(new ThreadCount(tables));
//启动线程
add.start();
del.start();
count.start();

/**
*添加对象线程
*/
private static class ThreadAdd implements Runnable
private Map<Integer, Object> table;

public ThreadAdd(Map<Integer, Object> tables)
this.table=tables;

public void run()
// TODO Auto-generated method stub
for(int i=0;i<10;i++)
table.put(i, new Object());
System.out.println("添加对象,序号为:"+i);



/**
*删除对象线程
*/
private static class ThreadDel implements Runnable
private Map<Integer, Object> table;

public ThreadDel(Map<Integer, Object> table)
this.table=table;

public void run()
// TODO Auto-generated method stub
for(int i=0;i<10;i++)
try
Thread.sleep(100);
catch (InterruptedException e)
// TODO Auto-generated catch block
e.printStackTrace();

table.remove(i);
System.out.println("移除对象,序号为:"+i);



/**
*统计线程
*/
private static class ThreadCount implements Runnable
private Map<Integer, Object> table;

public ThreadCount(Map<Integer, Object> table)
this.table=table;

public void run()
// TODO Auto-generated method stub
for(int i=0;i<10;i++)
try
Thread.sleep(50);
catch (InterruptedException e)
// TODO Auto-generated catch block
e.printStackTrace();

System.out.println("当前队列还剩"+table.size()+"个对象");




这是我的写的demo，不知道符合不符合你的意思，大家共同交流共同进步。追问

呵呵，以后一起交流，这是我Q：一四二四四三六八八一。

参考技术A Hashtable 表示键/值对的集合，这些键/值对根据键的哈希代码进行组织,它的Key不能为null,Value可以为null，这一点与Hashmap不同（本身不是线程安全的），对于Hashtable它是实现了IDictionary和ICollection接口的，它的key与value都是object类型的，不支持泛型，进行类型转换成需要装箱与拆箱（boxing,unboxing），这在性能肯定会有一些影响，所以，微软这边给出了支持泛型的键值对集合Dictionary，而Dictionary本身也不是线程安全的，我们需要对它加锁(lock)，才能避免多线程环境下产生的一些错误。
下面我们来看一下线程安全的Hashtable代码片断：
Hashtable ht = Hashtable.Synchronized(new Hashtable());
ht.Add("ok", null);
Console.WriteLine(ht["ok"]);

我们在来看一下Dictionary对象，可以使它基类提供的SyncRoot属性，来实现它内部对象的线程安全　　
Dictionary<string, string> dic = new Dictionary<string, string>();
lock ((dic as ICollection).SyncRoot)

dic.Add("ok", "ok value");


下面我们来做一个实例，还是Dictionary的线程安全问题，我们有两个线程，t1和t2，当我们为它加lock之后，t1纯种在进行dic.Ad操作时，t2并不能进行访问
当t1完成add操作后，t2线程才进行执行，这时它就可以改变dic 元素的值了，程序运行正常，但如果没有lock锁机制，t1与 t2线程谁先执行就不确定了，这时，
如果t1先执行，当然没有问题，但如果t2先操作了，程序出现异常，因为dic元素没有被add，所以无法改变其值。
看代码：

Dictionary<string, string> dic = new Dictionary<string, string>();

Thread t1 = new Thread(() =>

lock ((dic as ICollection).SyncRoot) //dic对象被保存，处于临界区

dic.Add("ok1", "ok value1");//这句先向字典添加

);

Thread t2 = new Thread(() =>

lock ((dic as ICollection).SyncRoot)

dic["ok1"] = "ok value2";

);

t1.Start();
t2.Start();
Thread.Sleep(2000);

而对于Hashtable来说，如果希望对它进行写加锁，读不加锁，也可以通过lock在代码段时去实现

Thread t1 = new Thread(() =>

lock (ht.SyncRoot)


ht.Add(i, i);

);

OK，对于hashtable的线程安全这块就说到这里，最后和大家说一下，咱们做WEB开发的工程师们，一定要注意线程安全这块的知识，因为你写的程序，肯定是处
于多线程环境下的 参考技术B 定义一个hashtable 对象

定义3个Thread 带参hashtable对象，分别作add,delete,size
三个线程运行,
注意
代码无需synchronized， hashtable是安全的
删除时，需要判断是否为空