Java 8 paralel akışı ve ThreadLocal

Question

Java 8 paralel akışında bir ThreadLocal değerini nasıl kopyalayabilirim anlamaya çalışıyorum.

bu düşünün Yani eğer:

Main Thread: MAIN 
Parallel Consumer - 5: MAIN 
Parallel Consumer - 4: MAIN 
Parallel Consumer - 7: empty 
Parallel Consumer - 3: empty 
Parallel Consumer - 1: empty 
Parallel Consumer - 6: empty 
Parallel Consumer - 2: empty 
Parallel Consumer - 0: MAIN 

verir

public class ThreadLocalTest { 

     public static void main(String[] args) { 
      ThreadContext.set("MAIN"); 
      System.out.printf("Main Thread: %s\n", ThreadContext.get()); 

      IntStream.range(0,8).boxed().parallel().forEach(n -> { 
       System.out.printf("Parallel Consumer - %d: %s\n", n, ThreadContext.get()); 
      }); 
     } 

     private static class ThreadContext { 
      private static ThreadLocal<String> val = ThreadLocal.withInitial(() -> "empty"); 

      public ThreadContext() { 
      } 

      public static String get() { 
       return val.get(); 
      } 

      public static void set(String x) { 
       ThreadContext.val.set(x); 
      } 
     } 
    } 

beni her paralel için kökenli iş parçacığı içine ana() yönteminden ThreadLocal klonlamak için bir yol var mı yürütme?

Böyle yani benim sonucu olduğunu: yerine bir ilk

Main Thread: MAIN 
Parallel Consumer - 5: MAIN 
Parallel Consumer - 4: MAIN 
Parallel Consumer - 7: MAIN 
Parallel Consumer - 3: MAIN 
Parallel Consumer - 1: MAIN 
Parallel Consumer - 6: MAIN 
Parallel Consumer - 2: MAIN 
Parallel Consumer - 0: MAIN 

?

Answer 1

As Louis has stated in the comments , senin örneğin çok iyi lambda ifadesi tam kullanım durumları ne senin örnekten belli değil

public static void main(String[] args) { 
    String value = "MAIN"; 
    System.out.printf("Main Thread: %s\n", value); 

    IntStream.range(0,8).boxed().parallel().forEach(n -> { 
     System.out.printf("Parallel Consumer - %d: %s\n", n, value); 
    }); 
} 

yerel değişkenin değerini yakalayan indirgenebilir.

Eğer ipler ana parçacığından başladı olacak tam olarak ne biliyorsanız, alt iş parçacığı için ana akıştan değerlerin mirasını sağlamak için Bu sınıf ThreadLocal uzanan bir InheritableThreadLocal

kullanmayı düşünebilirsiniz : Bir çocuk iş parçacığı oluşturulduğunda, alt öğesinin, üst öğenin değerleri olduğu tüm kalıtımsal iş parçacığı yerel değişkenleri için başlangıç ​​değerleri alınır. Bir InheritableThreadLocal olarak val ilan Senin durumunda

, ForkJoinPool#commonPool() içinde parallel() için oluşturulan Thread örnekleri tembel oluşturulduğundan, hepsi main yöntemi (ve iplik) değer set devralan olacaktır. Bir şekilde kullanılırsa

Bu durumda olmazdı commonPool (veya parallel terminali operasyonu çağrısında ne varsa pool) kökeni dizisindeki InhertiableThreadLocal değerini ayarlamadan önce.