多线程——实现Callable接口

简介:

前两篇博客(多线程——继承Thread类多线程——实现Runnable接口 )介绍了java使用线程的两种方法。这篇博客继续介绍第三种方法——实现Callable接口。

 

先说一下Runnable和Callable的差别:

1、Callable规定的方法是call(),Runnable规定的方法是run().

2、Callable的任务运行后可返回值。而Runnable的任务是不能返回值得

3、call方法能够抛出异常,run方法不能够

4、运行Callable任务能够拿到一个Future对象,表示异步计算的结果。

它提供了检查计算是否完毕的方法。以等待计算的完毕,并检索计算的结果。通过Future对象能够了解任务运行情况,可取消任务的运行。还可获取运行结果。

 

还沿用前两篇博客的样例,仅仅只是这里稍作修改。如今我们不仅要输入单词的长度,并且还要求计算出字符串数组中全部单词的长度之和。

 

非常明显,这样一修改,多线程的运行体就须要有一个返回值,用以计算全部单词的长度之和。而runnable中的run方法是不能有返回值的,所以,这里我们仅仅能使用callable。详细代码例如以下:

 

package test;

import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;


public class Test1{
	public static void main(String [] args ) {
		String [] words = {"first","second","world","thread"};
		
		//创建一个线程池
		ExecutorService pool = Executors.newCachedThreadPool(  );
        Set<Future<Integer>> set = new HashSet<Future<Integer>>();
        
        for (String word: words) {
            Callable<Integer> callable = new testCallable(word);
            Future<Integer> future = pool.submit(callable);
            set.add(future);
        }
        int sum = 0;
        for (Future<Integer> future : set) {
            try {
				sum += future.get();
			} catch (InterruptedException e) {
				e.printStackTrace();
			} catch (ExecutionException e) {
				e.printStackTrace();
			}
        }
        System.out.println("数组中全部单词的总长度为:" + sum);
	}

	
}


class testCallable implements Callable<Integer>{
	private String word;
	
	public testCallable(String word){
		
		this.word = word;
	}
	
	@Override
	public Integer call() throws Exception {
		System.out.println(Thread.currentThread().getName() + ": 開始运行!" );
		try {
			//如果处理须要2秒
			Thread.currentThread().sleep(2000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println(Thread.currentThread().getName() + ": 正在处理!" );
		System.out.println(Thread.currentThread().getName() + ": " + word + "长度为:" + word.length());
		return Integer.valueOf(word.length()); 
	}
}

运行结果例如以下:

 pool-1-thread-1: 開始运行。
pool-1-thread-3: 開始运行。
pool-1-thread-4: 開始运行!


pool-1-thread-2: 開始运行!


pool-1-thread-1: 正在处理!
pool-1-thread-1: first长度为:5
pool-1-thread-3: 正在处理!


pool-1-thread-3: world长度为:5
pool-1-thread-2: 正在处理!
pool-1-thread-2: second长度为:6
pool-1-thread-4: 正在处理!
pool-1-thread-4: thread长度为:6
数组中全部单词的总长度为:22

 

至此,java中创建线程的三种方法都以介绍完成。当然,了解了这些仅仅能说明对于多线程你刚刚入门。很多其它关于多线程的知识还有待于我们继续发掘。深入研究。




本文转自mfrbuaa博客园博客,原文链接:http://www.cnblogs.com/mfrbuaa/p/5132853.html,如需转载请自行联系原作者

相关文章
|
2月前
|
Java 开发者
奇迹时刻!探索 Java 多线程的奇幻之旅:Thread 类和 Runnable 接口的惊人对决
【8月更文挑战第13天】Java的多线程特性能显著提升程序性能与响应性。本文通过示例代码详细解析了两种核心实现方式:Thread类与Runnable接口。Thread类适用于简单场景,直接定义线程行为;Runnable接口则更适合复杂的项目结构,尤其在需要继承其他类时,能保持代码的清晰与模块化。理解两者差异有助于开发者在实际应用中做出合理选择,构建高效稳定的多线程程序。
49 7
|
20天前
|
Java
领略Lock接口的风采,通过实战演练,让你迅速掌握这门高深武艺,成为Java多线程领域的武林盟主
领略Lock接口的风采,通过实战演练,让你迅速掌握这门高深武艺,成为Java多线程领域的武林盟主
25 7
|
2月前
|
Java 开发者
揭秘!为什么大神都爱用Lock接口处理线程同步?
揭秘!为什么大神都爱用Lock接口处理线程同步?
54 5
|
2月前
|
Java
在Java多线程领域,精通Lock接口是成为高手的关键。
在Java多线程领域,精通Lock接口是成为高手的关键。相较于传统的`synchronized`,Lock接口自Java 5.0起提供了更灵活的线程同步机制,包括可中断等待、超时等待及公平锁选择等高级功能。本文通过实战演练介绍Lock接口的核心实现——ReentrantLock,并演示如何使用Condition进行精确线程控制,帮助你掌握这一武林秘籍,成为Java多线程领域的盟主。示例代码展示了ReentrantLock的基本用法及Condition在生产者-消费者模式中的应用,助你提升程序效率和稳定性。
25 2
|
2月前
|
Java 开发者
在 Java 多线程编程中,Lock 接口正逐渐取代传统的 `synchronized` 关键字,成为高手们的首选
在 Java 多线程编程中,Lock 接口正逐渐取代传统的 `synchronized` 关键字,成为高手们的首选。相比 `synchronized`,Lock 提供了更灵活强大的线程同步机制,包括可中断等待、超时等待、重入锁及读写锁等高级特性,极大提升了多线程应用的性能和可靠性。通过示例对比,可以看出 Lock 接口通过 `lock()` 和 `unlock()` 明确管理锁的获取和释放,避免死锁风险,并支持公平锁选择和条件变量,使其在高并发场景下更具优势。掌握 Lock 接口将助力开发者构建更高效、可靠的多线程应用。
21 2
|
2月前
|
Java
多线程同步新姿势:Lock接口助你“一统江湖”!
多线程同步新姿势:Lock接口助你“一统江湖”!
39 2
|
2月前
|
安全 算法 Java
17 Java多线程(线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合)(下)
17 Java多线程(线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合)
64 6
|
2月前
|
存储 安全 Java
17 Java多线程(线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合)(中)
17 Java多线程(线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合)
70 5
|
2月前
|
存储 安全 Java
17 Java多线程(线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合)(上)
17 Java多线程(线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合)
63 3
|
4月前
|
存储 Java
详细解读Callable接口及Futrue接口详解
详细解读Callable接口及Futrue接口详解
17 0