【问题标题】:My ThreadLocal contains and returns null always我的 ThreadLocal 始终包含并返回 null
【发布时间】:2026-02-08 15:25:01
【问题描述】:

我想知道当我将 threadlocal.set() 设置为 32 个元素的集合时,它是如何没有存储数据的。 ThreadLocal.get() 总是返回 null;并且对应的 FutureTask 对象有一个结果属性 = NullPointerException。知道为什么 ThreadLocal 无法存储集合项吗?

public class MyCallable<T> implements Callable<Collection<T>> {

    public MyCallable( Collection<T> items ){
        tLocal = new ThreadLocal<Collection<T>>();
        tLocal.set( items );                    //SETS NULL ALTHOUGH the PARAMETER CONTAINS 32 ITEMS
    }

    @Override
    @SuppressWarnings("unchecked")
    public Collection<T> call() throws Exception {
        synchronized( lock ){
            ArrayList<T> _items = new ArrayList<T>();
            ArrayList<T> _e = ( ArrayList<T> ) tLocal.get();   //RETURNS NULL
            for( T item : _e ){
                _items = getPValue( item ));
            }
            return _items ;
        }
    }

    private ThreadLocal<Collection<T>> tLocal;

    private final Object lock = new Object();
}

使用sn-p:

List<Future<Collection<T>>> futures = new ArrayList<Future<Collection<T>>>();
ExecutorService pool = Executors.newFixedThreadPool( 8 );

        for( int x = 0; x < numBatches; ++x ){
            List<T> items = retrieveNext32Items( x );
            futures.add( pool.submit( new MyCallable<T>( items ));
        }

        pool.shutdown();

        for( Future<Collection<T>> future : futures ) {
            _items.addAll( future.get() );                  //future.outcome = NullPointerException 
        }

        return _items
}

【问题讨论】:

  • 您应该为 C# 或 Java 或其他任何类型添加标签。

标签: java multithreading concurrency thread-local


【解决方案1】:

存储在本地线程中的值是为特定线程存储的。因此,如果您将一个值存储在特定线程 t1 的本地线程中,并尝试使用同一本地线程从另一个线程 t2 获取该值……您将不会获得该值,但会获得空值。检查在线程本地设置值的线程是否与从线程本地检索值的线程相同

【讨论】:

    【解决方案2】:

    您在主线程中创建 MyCallable 类型的对象,然后将它们提交到线程池。因此 MyCallable 的构造函数在一个线程中调用,call 在另一个线程中调用。线程本地为每个线程保留一个单独的数据,所以难怪你会得到空值。

    我不明白你为什么使用本地线程。 items 应该是 MyCallable 中的一个简单字段。如果您修改了集合,最好将其复制到新集合中。

    【讨论】: