{{theTime}}

Search This Blog

Total Pageviews

How to add ThreadLocal variables in java


Use ThreadLocal class to provide thread-local variables. ThreadLocal instances are private static fields in classes that wish to associate state with a thread.

For Eg:

 import java.util.concurrent.atomic.AtomicInteger;

 public class UniqueThreadIdGen {

     private static final AtomicInteger id= new AtomicInteger(0);

     private static final ThreadLocal < Integer > uniqueNum = 
         new ThreadLocal < Integer > () {
             @Override protected Integer initialValue() {
                 return id.getAndIncrement();
         }
     };
 
     public static int getCurrentThreadId() {
         return id.get();
     }
 } 

No comments:

Kafka Consumer Parallelism

Kafka Parallel Consumer Options: Key-level parallelism:  Multiple threads process the messages from a single partition in parallel while ma...