庄周梦蝶

生活、程序、未来
   :: 首页 ::  ::  :: 聚合  :: 管理

Clojure的并发(五)binding和let

Posted on 2010-07-23 23:19 dennis 阅读(4972) 评论(1)  编辑  收藏 所属分类: Clojure
Clojure 的并发(一) Ref和STM
Clojure 的并发(二)Write Skew分析
Clojure 的并发(三)Atom、缓存和性能
Clojure 的并发(四)Agent深入分析和Actor
Clojure 的并发(五)binding和let
Clojure的并发(六)Agent可以改进的地方
Clojure的并发(七)pmap、pvalues和pcalls
Clojure的并发(八)future、promise和线程

五、binding和let

    前面几节已经介绍了Ref、Atom和Agent,其中Ref用于同步协调多个状态变量,Atom只能用于同步独立的状态变量,而Agent则是允许异步的状态更新。这里将介绍下binding,用于线程内的状态的管理。

1、binding和let:
当你使用def定义一个var,并传递一个初始值给它,这个初始值就称为这个var的root binding。这个root binding可以被所有线程共享,例如:
user=> (def foo 1)
#
'user/foo
    那么对于变量foo来说,1是它的root binding,这个值对于所有线程可见,REPL的主线程可见:
user=> foo
1
   启动一个独立线程查看下foo的值:
user=> (.start (Thread. #(println foo)))
nil
 
1
  可以看到,1这个值对于所有线程都是可见的。
 
  但是,利用binding宏可以给var创建一个thread-local级别的binding:
(binding [bindings] & body)

  binding的范围是动态的,binding只对于持有它的线程是可见的,直到线程执行超过binding的范围为止,binding对于其他线程是不可见的。
user=> (binding [foo 2] foo)
2

  粗看起来,binding和let非常相似,两者的调用方式近乎一致:
user=> (let [foo 2] foo)
2

  从一个例子可以看出两者的不同,定义一个print-foo函数,用于打印foo变量:
user=> (defn print-foo [] (println foo))
#
'user/print-foo

  foo不是从参数传入的,而是直接从当前context寻找的,因此foo需要预先定义。分别通过let和binding来调用print-foo:
user=> (let [foo 2] (print-foo))
1
nil

  可以看到,print-foo仍然打印的是初始值1,而不是let绑定的2。如果用binding:
user=> (binding [foo 2] (print-foo))
2
nil

   print-foo这时候打印的就是binding绑定的2。这是为什么呢?这是由于let的绑定是静态的,它并不是改变变量foo的值,而是用一个词法作用域的foo“遮蔽”了外部的foo的值。但是print-foo却是查找变量foo的值,因此let的绑定对它来说是没有意义的,尝试利用set!去修改let的foo:
user=> (let [foo 2] (set! foo 3))
java.lang.IllegalArgumentException: Invalid assignment target (NO_SOURCE_FILE:
12)
  
   Clojure告诉你,let中的foo不是一个有效的赋值目标,foo是不可变的值。set!可以修改binding的变量:
user=> (binding [foo 2] (set! foo 3) (print-foo))
3
nil

2、Binding的妙用:


Binding可以用于实现类似AOP编程这样的效果,例如我们有个fib函数用于计算阶乘:
user=> (defn fib [n]
         (loop [ n n r 
1]
            (
if (= n 1)
                r
                (recur (dec n) (
* n r)))))

然后有个call-fibs函数调用fib函数计算两个数的阶乘之和:
user=> (defn call-fibs [a b]
          (
+ (fib a) (fib b)))
#
'user/call-fibs
user=> (call-fibs 3 3)
12

  现在我们有这么个需求,希望使用memoize来加速fib函数,我们不希望修改fib函数,因为这个函数可能其他地方用到,其他地方不需要加速,而我们希望仅仅在调用call-fibs的时候加速下fib的执行,这时候可以利用binding来动态绑定新的fib函数:
user=> (binding [fib (memoize fib)] 
                (call
-fibs 9 10))
3991680

   在没有改变fib定义的情况下,只是执行call-fibs的时候动态改变了原fib函数的行为,这不是跟AOP很相似吗?

   但是这样做已经让call-fibs这个函数不再是一个“纯函数”,所谓“纯函数”是指一个函数对于相同的参数输入永远返回相同的结果,但是由于binding可以动态隐式地改变函数的行为,导致相同的参数可能返回不同的结果,例如这里可以将fib绑定为一个返回平方值的函数,那么call-fibs对于相同的参数输入产生的值就改变了,取决于当前的context,这其实是引入了副作用。因此对于binding的这种使用方式要相当慎重。这其实有点类似Ruby中的open class做monkey patch,你可以随时随地地改变对象的行为,但是你要承担相应的后果。

3、binding和let的实现上的区别


前面已经提到,let其实是词法作用域的对变量的“遮蔽”,它并非重新绑定变量值,而binding则是在变量的root binding之外在线程的ThreadLocal内存储了一个绑定值,变量值的查找顺序是先查看ThreadLocal有没有值,有的话优先返回,没有则返回root binding。下面将从Clojure源码角度分析。

变量在clojure是存储为Var对象,它的内部包括:

//这是变量的ThreadLocal值存储的地方
static ThreadLocal<Frame> dvals = new ThreadLocal<Frame>(){

    
protected Frame initialValue(){
        
return new Frame();
    }
};

volatile Object root;  //这是root binding
public final Symbol sym;   //变量的符号
public final Namespace ns;  //变量的namespace

通过def定义一个变量,相当于生成一个Var对象,并将root设置为初始值。

先看下let表达式生成的字节码:
(let [foo 3] foo)
字节码:
public class user$eval__4349 extends clojure/lang/AFunction  {

  
// compiled from: NO_SOURCE_FILE
  
// debug info: SMAP
eval__4349.java
Clojure
*S Clojure
*F
+ 1 NO_SOURCE_FILE
NO_SOURCE_PATH
*L
0#1,1:0
*E

  
// access flags 25
  public final static Ljava/lang/Object; const__0

  
// access flags 9
  public static <clinit>()V
   L0
    LINENUMBER 
2 L0
    ICONST_3
    INVOKESTATIC java
/lang/Integer.valueOf (I)Ljava/lang/Integer;
    PUTSTATIC user$eval__4349.const__0 : Ljava
/lang/Object;

    RETURN
    MAXSTACK 
= 0
    MAXLOCALS 
= 0

  
// access flags 1
  public <init>()V
   L0
    LINENUMBER 
2 L0
   L1
    ALOAD 
0
    INVOKESPECIAL clojure
/lang/AFunction.<init> ()V
   L2
    RETURN
    MAXSTACK 
= 0
    MAXLOCALS 
= 0

  
// access flags 1
  public invoke()Ljava/lang/Object; throws java/lang/Exception 
   L0
    LINENUMBER 
2 L0
    GETSTATIC user$eval__4349.const__0 : Ljava
/lang/Object;
    ASTORE 
1
   L1
    ALOAD 
1
   L2
    LOCALVARIABLE foo Ljava
/lang/Object; L1 L2 1
   L3
    LOCALVARIABLE 
this Ljava/lang/Object; L0 L3 0
    ARETURN
    MAXSTACK 
= 0
    MAXLOCALS 
= 0
}

    可以看到foo并没有形成一个Var对象,而仅仅是将3存储为静态变量,最后返回foo的时候,也只是取出静态变量,直接返回,没有涉及到变量的查找。let在编译的时候,将binding作为编译的context静态地编译body的字节码,body中用到的foo编译的时候就确定了,没有任何动态性可言。

    再看同样的表达式替换成binding宏,因为binding只能重新绑定已有的变量,所以需要先定义foo:
user=> (def foo 100)
#
'user/foo
user=> (binding [foo 3] foo)

    binding是一个宏,展开之后等价于:
(let []
         (push
-thread-bindings (hash-map (var foo) 3))
         (
try
            foo
         (
finally
            (pop
-thread-bindings))))

    首先是将binding的绑定列表转化为一个hash-map,其中key为变量foo,值为3。函数push-thread-bindings:

(defn push-thread-bindings
     [bindings]
     (clojure.lang.Var
/pushThreadBindings bindings))
   
    其实是调用Var.pushThreadBindings这个静态方法:
public static void pushThreadBindings(Associative bindings){
    Frame f 
= dvals.get();
    Associative bmap 
= f.bindings;
    
for(ISeq bs = bindings.seq(); bs != null; bs = bs.next())
        {
        IMapEntry e 
= (IMapEntry) bs.first();
        Var v 
= (Var) e.key();
        v.validate(v.getValidator(), e.val());
        v.count.incrementAndGet();
        bmap 
= bmap.assoc(v, new Box(e.val()));
        }
    dvals.set(new Frame(bindings, bmap, f));
}

    pushThreadBindings是将绑定关系放入一个新的frame(新的context),并存入ThreadLocal变量dvals。pop-thread-bindings函数相反,弹出一个Frame,它实际调用的是Var.popThreadBindings静态方法:
public static void popThreadBindings(){
    Frame f 
= dvals.get();
    
if(f.prev == null)
        
throw new IllegalStateException("Pop without matching push");
    
for(ISeq bs = RT.keys(f.frameBindings); bs != null; bs = bs.next())
        {
        Var v 
= (Var) bs.first();
        v.count.decrementAndGet();
        }
    dvals.set(f.prev);
}

   在执行宏的body表达式,也就是取foo值的时候,实际调用的是Var.deref静态方法取变量值:
final public Object deref(){
    
//先从ThreadLocal找
    Box b = getThreadBinding();
    
if(b != null)
        
return b.val;
    
//如果有定义初始值,返回root binding
    if(hasRoot())
        
return root;
    
throw new IllegalStateException(String.format("Var %s/%s is unbound.", ns, sym));
}

    看到是先尝试从ThreadLocal找:
final Box getThreadBinding(){
    
if(count.get() > 0)
        {
        IMapEntry e 
= dvals.get().bindings.entryAt(this);
        
if(e != null)
            
return (Box) e.val();
        }
    
return null;
}

   找不到,如果有初始值就返回初始的root binding,否则抛出异常:Var user/foo is unbound.
   binding表达式最后生成的字节码,做的就是上面描述的这些函数调用,有兴趣地可以自行分析。

   

评论

# re: Clojure的并发(五)binding和let  回复  更多评论   

2010-07-26 09:43 by clojans
楼主应该加上let和binding表达式返回函数的用途和区别就更加完美了。

只有注册用户登录后才能发表评论。


网站导航: