`
lzkyo
  • 浏览: 468206 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

使用ThreadLocal,隔离多个线程之间的共享冲突

    博客分类:
  • Java
阅读更多

 早在Java 1.2推出之时,Java平台中就引入了一个新的支持:java.lang.ThreadLocal,其实ThreadLocal并非是一个线程的本地实现版本,它并不是一个Thread,而是thread local variable(线程局部变量)。也许把它命名为ThreadLocalVar更加合适。线程局部变量(ThreadLocal)其实的功用非常简单,就是为每一个使用该变量的线程都提供一个变量值的副本,是每一个线程都可以独立地改变自己的副本,而不会和其它线程的副本冲突。从线程的角度看,就似乎每一个线程都完全拥有该变量。线程局部变量并不是Java的新发明,在其它的一些语言编译器实现(如IBM XL FORTRAN)中,它在语言的层次提供了直接的支持。因为Java中没有提供在语言层次的直接支持,而是提供了一个ThreadLocal的类来提供支持,所以,在Java中编写线程局部变量的代码相对比较笨拙,这也许是线程局部变量没有在Java中得到很好的普及的一个原因吧。
   ThreadLocal的设计
首先看看ThreadLocal的接口:

Java代码 复制代码
  1. Object get() ; // 返回当前线程的线程局部变量副本   
  2. protected Object initialValue(); // 返回该线程局部变量的当前线程的初始值   
  3. void set(Object value); // 设置当前线程的线程局部变量副本的值   
  4. void remove() ;// 移除此线程局部变量的值。  
Object get() ; // 返回当前线程的线程局部变量副本
protected Object initialValue(); // 返回该线程局部变量的当前线程的初始值
void set(Object value); // 设置当前线程的线程局部变量副本的值
void remove() ;// 移除此线程局部变量的值。



  值得注重的是initialValue(),该方法是一个protected的方法,显然是为了子类重写而特意实现的。该方法返回当前线程在该线程局部变量的初始值,这个方法是一个延迟调用方法,在一个线程第1次调用get()或者set(Object)时才执行,并且仅执行1次。ThreadLocal中的确实实现直接返回一个null:

Java代码 复制代码
  1. protected Object initialValue() { return null; }  
protected Object initialValue() { return null; }

  ThreadLocal是如何做到为每一个线程维护变量的副本的呢?其实实现的思路很简单,在ThreadLocal类中有一个Map,用于存储每一个线程的变量的副本。比如下面的示例实现:

Java代码 复制代码
  1. public class ThreadLocal   
  2. {   
  3.  private Map values = Collections.synchronizedMap(new HashMap());   
  4.  public Object get()   
  5.  {   
  6.   Thread curThread = Thread.currentThread();    
  7.   Object o = values.get(curThread);    
  8.   if (o == null && !values.containsKey(curThread))   
  9.   {   
  10.    o = initialValue();   
  11.    values.put(curThread, o);    
  12.   }   
  13.   return o;    
  14.  }   
  15.   
  16.  public void set(Object newValue)   
  17.  {   
  18.   values.put(Thread.currentThread(), newValue);   
  19.  }   
  20.   
  21.  public Object initialValue()   
  22.  {   
  23.   return null;    
  24.  }   
  25. }  
public class ThreadLocal
{
 private Map values = Collections.synchronizedMap(new HashMap());
 public Object get()
 {
  Thread curThread = Thread.currentThread(); 
  Object o = values.get(curThread); 
  if (o == null && !values.containsKey(curThread))
  {
   o = initialValue();
   values.put(curThread, o); 
  }
  return o; 
 }

 public void set(Object newValue)
 {
  values.put(Thread.currentThread(), newValue);
 }

 public Object initialValue()
 {
  return null; 
 }
}

  当然,这并不是一个工业强度的实现,但JDK中的ThreadLocal的实现总体思路也类似于此。

例子:

Java代码 复制代码
  1. public class RequestContext {   
  2.   
  3.     private static ThreadLocal requestContext = new RequestContextThreadLocal();   
  4.   
  5.     private static class RequestContextThreadLocal extends ThreadLocal {   
  6.                   //设定此线程局部变量的当前线程的初始值   
  7.         protected Object initialValue() {   
  8.             return new RequestContext(new HashMap());   
  9.         }   
  10.     }   
  11.        
  12.     public static RequestContext getContext() {   
  13.         //返回此线程局部变量的当前线程副本中的值   
  14.         RequestContext context = (RequestContext) requestContext.get();   
  15.            
  16.         if (context == null) {   
  17.             context = new RequestContext(new HashMap());   
  18.             setContext(context);   
  19.         }   
  20.            
  21.         return context;   
  22.     }   
  23.        
  24.   
  25.     public static void setContext(RequestContext context) {   
  26.           //将此线程局部变量的当前线程副本中的值设置为指定值   
  27.                requestContext.set(context);   
  28.     }   
  29. }  
public class RequestContext {

	private static ThreadLocal requestContext = new RequestContextThreadLocal();

	private static class RequestContextThreadLocal extends ThreadLocal {
                  //设定此线程局部变量的当前线程的初始值
		protected Object initialValue() {
			return new RequestContext(new HashMap());
		}
	}
	
	public static RequestContext getContext() {
		//返回此线程局部变量的当前线程副本中的值
		RequestContext context = (RequestContext) requestContext.get();
		
		if (context == null) {
			context = new RequestContext(new HashMap());
			setContext(context);
		}
		
		return context;
	}
	

	public static void setContext(RequestContext context) {
	      //将此线程局部变量的当前线程副本中的值设置为指定值
               requestContext.set(context);
	}
}



   当然ThreadLocal并不能替代同步机制,两者面向的问题领域不同。同步机制是为了同步多个线程对相同资源的并发访问,是为了多个线程之间进行通信的有效方式;而ThreadLocal是隔离多个线程的数据共享,从根本上就不在多个线程之间共享资源(变量),这样当然不需要对多个线程进行同步了。所以,假如你需要进行多个线程之间进行通信,则使用同步机制;假如需要隔离多个线程之间的共享冲突,可以使用ThreadLocal。

分享到:
评论

相关推荐

    ThreadLocal的几种误区

    ThreadLocal是Java编程中一种非常特殊的变量类型,它主要用于在多线程环境下为每个线程提供独立的变量副本,从而避免了线程间的数据共享和冲突。然而,ThreadLocal在理解和使用过程中容易产生一些误区,这里我们将...

    java核心知识点学习----多线程间的数据共享和对象独立,ThreadLocal详解.pdf

    但是,这种方式并不保证线程安全,如果有多个线程同时修改HashMap,仍然可能引发竞态条件。为了确保安全,可以使用ConcurrentHashMap,它提供了线程安全的并发操作。 2. **ThreadLocal详解**: ThreadLocal是Java...

    java中ThreadLocal类的使用

    线程局部变量意味着每个线程都拥有自己独立的变量副本,互不干扰,这在多线程编程中尤其有用,可以避免数据共享带来的同步问题。下面我们将深入探讨`ThreadLocal`的工作原理、使用场景以及常见误区。 `ThreadLocal`...

    ThreadLocal简单Demo

    4. **减少锁的使用**: 当多个线程需要共享同一资源,但每个线程只需要读取自己相关的数据时,`ThreadLocal`可以避免锁的使用,提升效率。 **注意事项** - 使用`ThreadLocal`后,应确保及时清理不再使用的变量,...

    ThreadLocal的用处

    ThreadLocal是Java编程语言中的一个强大工具,它主要用于在多线程环境中为每个线程提供独立的变量副本。这个机制确保了线程之间的数据隔离,避免了共享状态带来的并发问题,提高了程序的安全性和效率。ThreadLocal是...

    彻底理解ThreadLocal 1

    传统的线程同步,如使用`synchronized`关键字,会使得多个线程在访问共享资源时需要排队执行,确保了线程安全,但牺牲了并发性能。而ThreadLocal则通过为每个线程创建单独的变量副本,消除了并发冲突,提升了程序的...

    ThreadLocal和事务

    通过ThreadLocal,我们可以确保每个请求的Model层操作都在自己的事务范围内,这样即使在处理过程中出现异常,也不会影响到其他请求的事务状态,从而实现了MVC三层结构之间的良好隔离。 总结来说,这个小型练习展示...

    Java多线程编程之ThreadLocal线程范围内的共享变量

    1. **数据隔离**:ThreadLocal确保了每个线程都有自己的变量副本,避免了多线程之间的数据竞争,从而提高了代码的安全性和可维护性。 2. **简化同步管理**:使用ThreadLocal,开发者无需担心同步问题,因为每个线程...

    java事务 - threadlocal

    Java事务和ThreadLocal是两种...事务用于保证数据库操作的原子性和一致性,ThreadLocal则为每个线程提供了独立的数据空间,避免了线程间的数据冲突。理解并熟练运用这两个概念,对于编写高效、安全的并发代码至关重要。

    Quartz-ThreadLocal.rar

    2. **避免并发冲突**:如果一个任务在执行过程中需要使用一些共享资源,但又不希望引入锁或同步机制,可以考虑使用 ThreadLocal 来存储每个线程的私有实例。 3. **状态传递**:在 Quartz 作业的执行过程中,...

    JAVA并发-自问自答学ThreadLocal.pdf

    在Java的并发编程中,ThreadLocal是一个非常重要的概念,它可以帮助我们创建独立于线程的变量副本,避免了在多线程共享数据时可能出现的竞态条件。 1. **ThreadLocal的工作原理**: - 每个ThreadLocal实例都会为每...

    threadlocal.rar

    ThreadLocal的工作原理可以这样理解:每个ThreadLocal实例都会为每个线程创建一个单独的存储空间,也就是说,当多个线程访问同一个ThreadLocal实例时,每个线程都有自己独立的副本,互不干扰。ThreadLocal并不提供...

    8个案例详解教会你ThreadLocal.docx

    - `synchronized` 作用于实例方法、静态方法或代码块,限制多个线程对同一对象的访问;而 `ThreadLocal` 变量则是在每个线程内部维护独立的实例,无需担心线程安全问题。 2. **存储位置** - `ThreadLocal` 变量...

    java中ThreadLocal详解

    通常情况下,当多个线程共享某个变量时,可能会引发线程安全问题。而`ThreadLocal`则提供了另一种思路:为每个使用该变量的线程分配独立的副本,这样一来,每个线程拥有自己的变量副本,互不影响,从而避免了线程...

    ThreadLocal详解

    例如,在Spring的DAO模板类中,尽管底层的数据连接或会话资源是非线程安全的,但是通过使用ThreadLocal,可以为每个线程绑定独立的数据连接或会话,使得多个DAO可以复用同一个模板实例而不会发生资源冲突,极大地...

    ThreadLocal分析

    ThreadLocal是Java编程语言中的一个强大工具,它主要用于在多线程环境中为每个线程提供独立的变量副本,避免了线程之间的数据共享问题,从而简化了并发编程。这个概念在理解和使用上都有一定的深度,涉及到Java内存...

    共享线程和局部存储技术

    这样可以避免多线程环境中数据冲突的问题,同时也提供了线程间数据隔离,确保每个线程可以有自己的私有变量。 在多线程编程中,线程局部存储可以用来存储线程特有的状态,如线程ID、线程局部变量等。与全局变量不同...

    生产者消费者 多线程

    这在多线程环境下非常有用,特别是当需要在多个线程之间隔离状态时,比如在数据库连接池中,每个线程可以有自己的连接对象,而无需担心其他线程的干扰。 在生产者消费者模型中,`ThreadLocal`可能不直接用于缓冲区...

    Java多线程编程中ThreadLocal类的用法及深入

    总结一下,ThreadLocal是Java中处理多线程环境下的线程安全问题的一个有效手段,它可以为每个线程提供独立的变量副本,避免了共享状态导致的冲突。通过合理使用ThreadLocal,我们可以创建线程安全的代码,提高程序的...

    32.8、高并发线程1

    线程安全问题通常出现在共享资源的并发环境中,例如,当多个线程同时访问并修改一个全局变量时,可能导致数据的不一致性和并发错误。`ThreadLocal`就是为了解决这类问题而设计的。在给定的例子中,DAO层的数据库连接...

Global site tag (gtag.js) - Google Analytics