Java에서 멀티스레딩을 구현하는 방법은 무엇입니까? (코드 예)-java지도 시간-php.cn

이 기사에서는 Java에서 멀티스레딩을 구현하는 방법을 설명합니다. (코드 샘플)에는 특정 참조 값이 있습니다. 도움이 필요한 친구가 참조할 수 있기를 바랍니다.

방법 1: 클래스를 상속하고 run() 메서드를 재정의합니다.

스레드를 생성합니다. class 하위 클래스에 run()을 다시 작성하고 스레드에서 실행할 코드를 추가하면 됩니다.

다음은 예입니다.

　public class MyThread extends Thread
　　{
　　　int count= 1, number;
　　　public MyThread(int num)
　　　{
　　　　number = num;
　　　　System.out.println
　　　　("创建线程 " + number);
　　　}
　　　public void run() {
　　　　while(true) {
　　　　　System.out.println
　　　　　　("线程 " + number + ":计数 " + count);
　　　　　if(++count== 6) return;
　　　　}
　　}
　　public static void main(String args[])
　　{
　　　for(int i = 0;i 〈 5; i++) new MyThread(i+1).start();
　　}
　}

로그인 후 복사

이 방법은 간단하고 명확하며 모든 사람의 습관에 부합하지만 큰 단점도 있습니다. 즉, 우리 클래스가 클래스에서 상속된 경우(예를 들어 애플릿은 Applet 클래스에서 상속해야 함) 더 이상 에서 상속할 수 없습니다. Thread 클래스, 지금 새 클래스를 만들고 싶지 않다면 어떻게 해야 할까요?

새로운 방법을 모색해 볼 수도 있습니다. Thread 클래스의 하위 클래스를 생성하지 않고 직접 생성합니다. 이를 사용하면 메소드를 Thread 클래스의 인스턴스에 매개변수로 전달할 수 있으며 이는 콜백 함수와 다소 유사합니다. 하지만 Java 포인터가 없습니다. 이 메서드가 포함된 클래스의 인스턴스만 전달할 수 있습니다.

그러면 이 메서드를 포함하도록 이 클래스를 제한하는 방법은 무엇일까요? 물론 인터페이스를 사용하세요! (추상 클래스도 만족할 수 있지만 상속이 필요합니다. 이 새로운 방법을 채택하는 이유는 단지 상속으로 인한 제한을 피하기 위함이 아닐까요?)

Java #🎜 🎜 # 이 메소드를 지원하기 위해 java.lang.Runnable 인터페이스를 제공합니다.

방법 2: 구현 실행 가능 인터페이스

Runnable

인터페이스에는 메서드가 하나만 있습니다run(), 자체 클래스 구현을 선언합니다# 🎜🎜 #Runnableinterface를 제공하고 이 메서드를 제공하면 스레드 코드를 작성하면 작업의 이 부분이 완료됩니다. 하지만 Runnable 인터페이스는 스레드를 지원하지 않으므로 Thread도 생성해야 합니다. class 예, 이 작업은 Thread 클래스 public Thread(Runnable target);#🎜의 생성자를 통해 수행됩니다. 🎜# 성취. 예는 다음과 같습니다.

public class MyThread implements Runnable
　　{
　　　int count= 1, number;
　　　public MyThread(int num)
　　　{
　　　　number = num;
　　　　System.out.println("创建线程 " + number);
　　　}
　　　public void run()
　　　{
　　　　while(true)
　　　　{
　　　　　System.out.println
　　　　　("线程 " + number + ":计数 " + count);
　　　　　if(++count== 6) return;
　　　　}
　　　}
　　　public static void main(String args[])
　　　{
　　　　for(int i = 0; i 〈 5;i++) new Thread(new MyThread(i+1)).start();
　　　}
　　}

로그인 후 복사

엄밀히 말하면

Thread

하위 클래스의 인스턴스를 생성하는 것도 가능하지만 다음 사항에 유의해야 합니다. , 하위 클래스는 Thread 클래스의 run 메서드를 재정의해서는 안 됩니다. 그렇지 않으면 스레드가 실행 run 메서드이며 Runnable 인터페이스 #을 구현하는 데 사용하는 클래스가 아닙니다. 🎜🎜# run 방법을 사용해보세요.
Runnable

인터페이스를 사용하여 멀티 스레딩을 구현하면 모든 코드를 하나의 클래스에 포함할 수 있으므로 도움이 됩니다. 캡슐화의 단점은 하나의 코드 세트만 사용할 수 있다는 것입니다. 여러 스레드를 생성하고 각 스레드가 서로 다른 코드를 실행하도록 하려면 이 경우 대부분의 경우 여전히 추가 클래스를 생성해야 합니다. 여러 클래스를 사용하는 것이 더 좋습니다

Thread 을 상속하여 간결하게 만듭니다.

方法三、使用ExecutorService、Callable、Future实现有返回结果的多线程

ExecutorService、Callable、Future这个对象实际上都是属于Executor框架中的功能类。想要详细了解Executor框架的可以访问http://www.javaeye.com/topic/366591 ，这里面对该框架做了很详细的解释。返回结果的线程是在JDK1.5中引入的新特征，确实很实用，有了这种特征我就不需要再为了得到返回值而大费周折了，而且即便实现了也可能漏洞百出。

可返回值的任务必须实现Callable接口，类似的，无返回值的任务必须Runnable接口。执行Callable任务后，可以获取一个Future的对象，在该对象上调用get就可以获取到Callable任务返回的Object了，再结合线程池接口ExecutorService就可以实现传说中有返回结果的多线程了。下面提供了一个完整的有返回结果的多线程测试例子，在JDK1.5下验证过没问题可以直接使用。代码如下：

import java.util.concurrent.*;  
import java.util.Date;  
import java.util.List;  
import java.util.ArrayList;  

@SuppressWarnings("unchecked")  

public class Test {  
public static void main(String[] args) throws ExecutionException,  
    InterruptedException {  
   System.out.println("----程序开始运行----");  
   Date date1 = new Date();  
   int taskSize = 5;  
   // 创建一个线程池  
   ExecutorService pool = Executors.newFixedThreadPool(taskSize);  
   // 创建多个有返回值的任务  
   List list = new ArrayList();  
   for (int i = 0; i < taskSize; i++) {  
    Callable c = new MyCallable(i + " ");  
    // 执行任务并获取Future对象  
    Future f = pool.submit(c);  
    // System.out.println(">>>" + f.get().toString());  
    list.add(f);  
   }  
   // 关闭线程池  
   pool.shutdown();  
   // 获取所有并发任务的运行结果  
   for (Future f : list) {  
    // 从Future对象上获取任务的返回值，并输出到控制台  
    System.out.println(">>>" + f.get().toString());  
   }  
   Date date2 = new Date();  
   System.out.println("----程序结束运行----，程序运行时间【"  
     + (date2.getTime() - date1.getTime()) + "毫秒】");  
}  
}  
class MyCallable implements Callable {  
private String taskNum;  
MyCallable(String taskNum) {  
   this.taskNum = taskNum;  
}  
public Object call() throws Exception {  
   System.out.println(">>>" + taskNum + "任务启动");  
   Date dateTmp1 = new Date();  
   Thread.sleep(1000);  
   Date dateTmp2 = new Date();  
   long time = dateTmp2.getTime() - dateTmp1.getTime();  
   System.out.println(">>>" + taskNum + "任务终止");  
   return taskNum + "任务返回运行结果,当前任务时间【" + time + "毫秒】";  
}  
}

로그인 후 복사

代码说明：

上述代码中Executors类，提供了一系列工厂方法用于创先线程池，返回的线程池都实现了ExecutorService接口。

public static ExecutorService newFixedThreadPool(int nThreads)

로그인 후 복사

创建固定数目线程的线程池。

public static ExecutorService newCachedThreadPool()

로그인 후 복사

创建一个可缓存的线程池，调用execute 将重用以前构造的线程（如果线程可用）。如果现有线程没有可用的，则创建一个新线程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。

public static ExecutorService newSingleThreadExecutor()

로그인 후 복사

创建一个单线程化的Executor。

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)

로그인 후 복사

创建一个支持定时及周期性的任务执行的线程池，多数情况下可用来替代Timer类。
ExecutoreService提供了submit()方法，传递一个Callable，或Runnable，返回Future。如果Executor后台线程池还没有完成Callable的计算，这调用返回Future对象的get()方法，会阻塞直到计算完成。