使用 ThreadLocal 来解决多线程之间数据共享

private static ThreadLocal<String> uuID = new ThreadLocal<String>(){

protected synchronized String initialValue(){

return null;

}

};

public static String getNextUUID(){

try {

if(uuID.get() != null)

return uuID.get();

uuID.set(UUIDUtil.replaceString(UUIDUtil.getUUID(), "-", ‘-‘));

return uuID.get();

} catch (Exception e) {

e.printStackTrace();

}

return null;

}

//测试线程

package com.ushi.montor.test;

import com.ushi.montor.util.UUIDUtil;

public class TestClient extends Thread {

public void run(){

for(int i = 0 ; i < 3; i++){

System.out.println("thread[" + Thread.currentThread().getName()+"] sn[" + UUIDUtil.getNextUUID() + "]");

}

}

}

//测试类

package com.ushi.montor.test;

public class TestThreadLocal {

public static void main(String[] args) {

//  3个线程共享sn,各自产生序列号

TestClient t1 = new TestClient();

TestClient t2 = new TestClient();

TestClient t3 = new TestClient();

t1.start();

t2.start();

t3.start();

}

}

//执行结果

thread[Thread-1] sn[6c9324d1b7774e2891179c57294b5e52]

thread[Thread-1] sn[6c9324d1b7774e2891179c57294b5e52]

thread[Thread-1] sn[6c9324d1b7774e2891179c57294b5e52]

thread[Thread-0] sn[402526757d824d0988572b706dea7334]

thread[Thread-0] sn[402526757d824d0988572b706dea7334]

thread[Thread-0] sn[402526757d824d0988572b706dea7334]

thread[Thread-2] sn[1b10c4b83a43401da369c823cd1f7c2d]

thread[Thread-2] sn[1b10c4b83a43401da369c823cd1f7c2d]

thread[Thread-2] sn[1b10c4b83a43401da369c823cd1f7c2d]

时间: 2024-11-15 06:10:59

使用 ThreadLocal 来解决多线程之间数据共享的相关文章

解决多线程并发问题

1.文件锁 如果对该表的更新或插入的操作,都会经过一个统一的文件,这种方式是可以解决的多进程并发的问题: 实现方式如下: public static function cbInventoryReserve() { $LOCK_FILE_PATH = $_SERVER['DOCUMENT_ROOT']."wmsinventoryapi/inventory/InventoryReserve.php"; $fp = fopen( $LOCK_FILE_PATH, "r"

Android多线程研究(6)——多线程之间数据隔离

在上一篇<Android多线程研究(5)--线程之间共享数据>中对线程之间的数据共享进行了学习和研究,这一篇我们来看看如何解决多个线程之间的数据隔离问题,什么是数据隔离呢?比如说我们现在开启了两个线程,这两个线程都要同时给同一个全局变量data赋值,各个线程操作它赋值后的变量数据,这里就需要用到隔离.先看一段代码: import java.util.Random; public class ThreadLocalTest { private static int data = 0; publi

JAVA多线程之间共享数据BlockingQueue介绍

在JAVA的Concurrent包中,BlockingQueue很好的解决了多线程中,如何高效安全“传输”数据的问题.通过这些高效并且线程安全的队列类,为我们快速搭建高质量的多线程程序带来极大的便利.本文详细介绍了BlockingQueue家庭中的所有成员,包括他们各自的功能以及常见使用场景. 一.认识BlockingQueue 阻塞队列,顾名思义,首先它是一个队列,而一个队列在数据结构中所起的作用大致如下图所示:  从上图我们可以很清楚看到,通过一个共享的队列,可以使得数据由队列的一端输入,从

【java】-- 多线程之间实现通讯

1.多线程之间如何实现通讯 1.1.什么是多线程之间通讯? 多线程之间通讯,其实就是多个线程在操作同一个资源,但是操作的动作不同. 画图演示 1.2.多线程之间通讯需求 需求:第一个线程写入(input)用户,另一个线程取读取(out)用户.实现读一个,写一个操作. 2.代码实现基本实现 2.1.共享资源源实体类 class Res {      public String userSex;      public String userName; } 输入线程资源 class IntThrad

多线程之间实现通讯

多线程之间如何实现通讯 什么是多线程之间通讯?  多线程之间通讯,其实就是多个线程在操作同一个资源,但是操作的动作不同. 多线程之间通讯需求 需求:第一个线程写入(input)用户,另一个线程取读取(out)用户.实现读一个,写一个操作. 代码实现基本实现 共享资源源实体类 class Res { public String userSex; public String userName; } 输入线程资源 class IntThrad extends Thread { private Res

多线程之间通讯

什么是多线程之间通信? 多个线程之间通讯,其实就是多个线程在操作同一个资源,但是操作的的动作不同. 如,一个线程对资源进行写的操作,一个线程对资源进行读的操作. 例子: 共享资源类: class Res { public String userSex; public String userName; } 写操作类 class IntThrad extends Thread { private Res res; public IntThrad(Res res) { this.res = res;

多线程之间的通信(等待唤醒机制、Lock 及其它线程的方法)

一.多线程之间的通信. 就是多个线程在操作同一份数据, 但是操作的方法不同. 如: 对于同一个存储块,其中有两个存储位:name   sex, 现有两个线程,一个向其中存放数据,一个打印其中的数据. 为了解决上述问题中的安全问题(在存放线程进行存放操作的时候, 打印线程不能对共有数据进行操作),所以应当对两个线程       操作共有数据的代码部分进行同步(使用synchronized(),来进行同步, 注意 :使用同一个对象作为同步锁. 二.等待唤醒机制. 在上述案例实现过后运行,会发现:打印

Nhibernate多线程之间Session的问题

? 背景:系统针对业务逻辑层提供了AOP的NHibernate Session,会话对象是通过Spring.net管理的.但在业务逻辑层里面有些方法实行了异步线程池调用数据访问接口,抛出异常提示:No Hibernate Session bound to thread, and configuration does not allow creation of non-transactional one here. ? 分析原因:当前线程和Spring.net创建Session绑定了,多线程直接切

如何用SingleThreadModel解决多线程安全问题

2.用SingleThreadModel解决多线程安全问题:(视频下载) (全部书籍) 前 面介绍的都是普通的Servlet.对于每一个用户请求,那些Servlet都会用线程的方式给予应答.这样比较节省系统的资源.Sun公司也给出了另外 一种方法,就是这节要介绍的SingleThreadModel的方法.当implement这个接口以后,你的Servlet就变成了另外一种模式工 作.即,每一个新用户的请求,都会生成一个新的Servlet实例来应答.这种方法有两个方面的弊病.一是性能太差,最后会把