java并发分段锁实践代码

以下是代码：

package cn.study.concurrency.ch11;

/**
* 锁分段
* @author xiaof
*
*/
public class StripedMap {
//同步策略：就是对数组进行分段上锁，n个节点用n%LOCKS锁保护
private static final int N_LOCKS = 16;
private final Node[] buckets;
private final Object[] locks;

private static class Node
{
private String name;
private Node next;
private String key;
private String value;
public String getValue() {
return value;
}
public void setValue(String value) {
this.value = value;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Node getNext() {
return next;
}
public void setNext(Node next) {
this.next = next;
}
public String getKey() {
return key;
}
public void setKey(String key) {
this.key = key;
}

}

public StripedMap(int numBuckets)
{
buckets = new Node[numBuckets];
//创建对应hash的锁
locks = new Object[N_LOCKS];
for(int i = 0; i < N_LOCKS; ++ i)
{
locks[i] = new Object();
}
}

private final int hash(Object key)
{
//取绝对值
return Math.abs(key.hashCode() % buckets.length);
}

//get和clear
public Object get(Object key)
{
int hash = hash(key);
synchronized(locks[hash % N_LOCKS])
{
//分段上锁
for(Node m = buckets[hash]; m != null; m = m.next)
{
if(m.key.equals(key))
return m.value;
}
}

return null;
}

/**
* 清除所有的数据，但是没有要求说要同时获取全部的锁的话，可以进行这样的释放操作
*/
public void clear()
{
for(int i = 0; i < buckets.length; ++i)
{
synchronized(locks[i % N_LOCKS])
{
buckets[i] = null;
}
}
}
}

以上就是本文的全部内容，希望对大家的学习有所帮助

您可能感兴趣的文章:

• java ConcurrentHashMap锁分段技术及原理详解
• Java 高并发九：锁的优化和注意事项详解
• Java 高并发四：无锁详细介绍
• Java线程并发中常见的锁机制详细介绍
• 深入解析Java并发程序中线程的同步与线程锁的使用
• java多线程并发中使用Lockers类将多线程共享资源锁定
• 使用JAVA实现高并发无锁数据库操作步骤分享