Java线程:线程安全类和Callable与Future(有返回值的线程)-阿里云开发者社区

开发者社区> liurio> 正文

Java线程:线程安全类和Callable与Future(有返回值的线程)

简介: 一、线程安全类   当一个类已经很好的同步以保护它的数据时,这个类就称为线程安全的。当一个集合是安全的,有两个线程在操作同一个集合对象,当第一个线程查询集合非空后,删除集合中所有元素的时候,第二个线程也来执行与第一个线程相同的操作,也许第一个线程查询后,第二个也查出非空,但是此时明显是不对的。
+关注继续查看

一、线程安全类

  当一个类已经很好的同步以保护它的数据时,这个类就称为线程安全的。当一个集合是安全的,有两个线程在操作同一个集合对象,当第一个线程查询集合非空后,删除集合中所有元素的时候,第二个线程也来执行与第一个线程相同的操作,也许第一个线程查询后,第二个也查出非空,但是此时明显是不对的。如:

 1 public class NameList { 
 2     private List nameList = Collections.synchronizedList(new LinkedList()); 
 3 
 4     public void add(String name) { 
 5         nameList.add(name); 
 6     } 
 7 
 8     public String removeFirst() { 
 9         if (nameList.size() > 0) { 
10             return (String) nameList.remove(0); 
11         } else { 
12             return null; 
13         } 
14     } 
15 }
 1 public class Test { 
 2     public static void main(String[] args) { 
 3         final NameList nl = new NameList(); 
 4         nl.add("aaa"); 
 5         class NameDropper extends Thread{ 
 6             public void run(){ 
 7                 String name = nl.removeFirst(); 
 8                 System.out.println(name); 
 9             } 
10         } 
11 
12         Thread t1 = new NameDropper(); 
13         Thread t2 = new NameDropper(); 
14         t1.start(); 
15         t2.start(); 
16     } 
17 }

  虽然集合对象private List nameList=Collections.synchronizedList(new LinkedList())是同步的,但是程序并不是线程安全的。

  原因是:一个线程操作列表的过程无法阻止另一个线程对列表的其他操作。解决办法是:在操作集合对象的NameList上面做一个同步。改写后的代码为:

 1 public class NameList { 
 2     private List nameList = Collections.synchronizedList(new LinkedList()); 
 3 
 4     public synchronized void add(String name) { 
 5         nameList.add(name); 
 6     } 
 7 
 8     public synchronized String removeFirst() { 
 9         if (nameList.size() > 0) { 
10             return (String) nameList.remove(0); 
11         } else { 
12             return null; 
13         } 
14     } 
15 }

  此时,一个线程访问其中一个方法时,其他线程等待。

二、Callable与Future

  通过实现Callable接口实现有返回值的任务,与Runnable接口处理无返回值的任务类似。

执行了Callable任务后,可以获得一个Future对象,在该对象上调用get就可以获得Callable任务返回的Object了。如:

 1 package Thread;
 2 
 3 import java.util.concurrent.Callable;
 4 import java.util.concurrent.ExecutionException;
 5 import java.util.concurrent.ExecutorService;
 6 import java.util.concurrent.Executors;
 7 import java.util.concurrent.Future;
 8 
 9 public class CallableTest {
10     public static void main(String[] args)throws ExecutionException,InterruptedException{
11         ExecutorService pool=Executors.newFixedThreadPool(2);
12         Callable c1=new MyCallable("A");
13         Callable c2=new MyCallable("B");
14         Future f1=pool.submit(c1);
15         Future f2=pool.submit(c2);
16         System.out.println(">>>"+f1.get().toString());
17         System.out.println(">>>"+f2.get().toString());
18         pool.shutdown();
19     }
20 }
21 class MyCallable implements Callable{
22     private String oid;
23     MyCallable(String oid){
24         this.oid=oid;
25     }
26     public Object call()throws Exception{
27         return oid+"任务返回的内容";
28     }
29     
30 }
View Code
1 >>>A任务返回的内容
2 >>>B任务返回的内容

 

当神已无能为力,那便是魔渡众生

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
线程安全性(第二章)
线程安全性 要编写线程安全的代码,其核心在于要对状态访问操作进行管理,特别是对共享的(Shared)和可变的(Mutable)状态的访问。 对象的状态:存储在状态变量(例如实例或静态域)中的数据,包括其他以来对象的域 共享(Shared):意味着变量可以由多个线程同时访问 可变(Mutable):变量的值在其生命周期内可以发生变化 一个对象是否需要使线程安全的,取决于它是否被多个线程访问。
893 0
什么是线程安全
什么是线程安全?         如果你的代码所在的进程中有多个线程在同时运行,而这些线程可能会同时运行这段代码。如果每次运行结果和单线程运行的结果是一样的,而且其他的变量的值也和预期的是一样的,就是线程安全的。
677 0
Java线程的生命周期(转)
Java线程的生命周期   一个线程的产生是从我们调用了start方法开始进入Runnable状态,即可以被调度运行状态,并没有真正开始运行,调度器可以将CPU分配给它,使线程进入Running状态,真正运行其中的程序代码。
832 0
java线程实现
线程的生命周期及五种基本状态关于Java线程的生命周期,请看下面这张图:新建状态(New):当线程对象创建后,即进入了新建状态,如:Thread t = new MyThread();就绪状态(Runnable):当调用线程对象的start()方法(t.start();),线程即进入就绪状态。处于就绪状态的线程,只是说明此线程已经做好了准备,随时等待CPU调度执行,并不是说执行了t.start()
2006 0
私有静态内部类实现线程安全的单例
利用私有静态内部类实现线程安全的单例
5592 0
03.Java基础(线程池和Callable<T>)
在以往的工作中,创建线程通常我们关注的都是Thread或者Runnable为主,其实忽略了另外一个比较有用的创建线程的方式,就是Callable接口,下边是Callable配合线程池实现异步任务 import java.
746 0
+关注
liurio
紧跟大神脚步,争做下个小神。
51
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载