java 8的多线程示例
java 8的多线程示例
提问于 2016-09-15 23:53:54
我需要一个多线程的Java 8示例。
我需要能够手动选择线程的数量。
在下面的示例中，我在使用Thread.currentThread().getName()时遇到了问题，我需要使用lambda表达式。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Thread {
public static void main(String args[]) {
ExecutorService service = Executors.newFixedThreadPool(10);
for (int i =0; i<100; i++){
service.submit(new Task(i));
}
}
final class Task implements Runnable{
private int taskId;
public Task(int id){
this.taskId = id;
}
@Override
public void run() {
System.out.println("Task ID : " + this.taskId +" performed by "
+ Thread.currentThread().getName());
}
}回答 3
Stack Overflow用户
回答已采纳
发布于 2016-09-16 01:08:56
使用IntStream可以很容易地实现Lambda。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.stream.IntStream;
public class ThreadLauncher
{
public static void main(String args[])
{
ExecutorService service = Executors.newFixedThreadPool(10);
IntStream.range(0, 100).forEach(i -> service.submit(new Task(i)));
}
}
final class Task
implements Runnable
{
private int taskId;
public Task(int id)
{
this.taskId = id;
}
@Override
public void run()
{
System.out.println("Task ID : " + this.taskId + " performed by "
+ Thread.currentThread().getName());
}
}Stack Overflow用户
发布于 2016-09-16 03:01:13
对于lambda，我建议：
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Main {
public static void main(String args[]) {
ExecutorService service = Executors.newFixedThreadPool(10);
for (int i =0; i < 100; i++) {
final int fi = i;
service.submit(() -> System.out.println("Task ID : " + fi + " performed by "
+ Thread.currentThread().getName()));
}
}
}或者如果你想在lambdas上全力以赴
public class Main {
public static void main(String args[]) {
ExecutorService service = Executors.newFixedThreadPool(10);
IntStream.range(0, 100)
.forEach(i -> service.submit(()
-> System.out.println("Task ID : " + i + " performed by " + Thread.currentThread().getName())));
}
}Stack Overflow用户
发布于 2020-03-12 15:20:37
希望这对某些人有帮助。一个由3个Thread组成的池被创建并并行运行。
public class threadClass {
ExecutorService executor = Executors.newFixedThreadPool(3);
public void multiThread() {
Runnable thread1 = () -> {
// perform some operation
System.out.println(Thread.currentThread().getName());
};
Runnable thread2 = () -> {
// perform some operation
System.out.println(Thread.currentThread().getName());
};
Runnable thread3 = () -> {
// perform some operation
System.out.println(Thread.currentThread().getName());
};
executor.execute(thread1);
executor.execute(thread2);
executor.execute(thread3);
executor.shutdown();
}}
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/39515447
复制相关文章
相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号