会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132360个问题
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器 481楼

package com.itbjsxt.TestThread;

class  A implements Runnable{
    private Thread C;
    public A(Thread C){
        this.C = C;
    }

    @Override
    public void run() {
        for (int i =0;i<10;i++){
            System.out.println(Thread.currentThread().getName()+"A"+i);
            if (i ==5){
                try {
                    C.join();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }

            }
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
               e.printStackTrace();
            }

        }
    }
}
class B implements Runnable{
    @Override
    public void run() {
        for (int i =0;i<15;i++){
            System.out.println(Thread.currentThread().getName()+"B"+i);
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        }
    }

}
public class ThreadTest1 {
    public static void main(String[] args) throws InterruptedException {

        Thread t1 = new Thread(new B());
        Thread t = new Thread(new A(t1));
        t.start();
        t1.start();
        for (int i =0;i<15;i++) {
            System.out.println(Thread.currentThread().getName() + " " + i);
            if (i ==2){
                t.join();

            }
        }
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
请问一下老师,这里面用到的this.C和直接C.join()执行结果一样那两者有什么区别呢,我不是很理解this


JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术 482楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器 485楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/常用类 486楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器 487楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/常用类 488楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/IO流技术 489楼

package com;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
/*发送消息线程*/
/**
 * 发送消息线程
 */
class Send1 extends Thread{
    private Socket socket;
    private Scanner scanner;
    public Send1(Socket socket,Scanner scanner){
        this.socket = socket;
        this.scanner = scanner;
    }
    @Override
    public void run() {
        this.sendMsg();
    }
    /**
     * 发送消息
     */
    private void sendMsg(){

        //创建向对方输出消息的流对象
        try(PrintWriter pw = new PrintWriter(this.socket.getOutputStream())){

            while(true){
                String msg = scanner.nextLine();
                pw.println(msg);
                pw.flush();
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

/**
 * 接收消息的线程
 */
class Receive1 extends Thread{
    private Socket socket;
    public Receive1(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        this.receiveMsg();
    }
    /**
     * 用于接收对方消息的方法
     */
    private void receiveMsg(){
        //创建用于接收对方发送消息的流对象
        try(BufferedReader br = new BufferedReader(new InputStreamReader(this.socket.getInputStream()))){

            while(true){
                String msg = br.readLine();
                System.out.println("他说:"+msg);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}
public class GoodTCP {
    public static void main(String[] args) {
        Scanner scanner = null;
        ServerSocket serverSocket = null;
        Socket socket = null;
        try{
            scanner = new Scanner(System.in);
            System.out.println("请输入:server,<port> 或者:<ip>,<port>");
            String str = scanner.nextLine();
            String[] arr = str.split(",");
            if("server".equals(arr[0])){
                //启动服务端
                System.out.println("TCP Server Listen at "+arr[1]+" .....");
                serverSocket = new ServerSocket(Integer.parseInt(arr[1]));
                socket = serverSocket.accept();
                System.out.println("连接成功!");

            }else{
                //启动客户端
               socket = new Socket(arr[0],Integer.parseInt(arr[1]));
                System.out.println("连接成功!");
            }
            //启动发送消息的线程
            new Send(socket,scanner).start();
            //启动接收消息的线程
            new Receive(socket).start();
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            if(serverSocket != null){
               try {
                   serverSocket.close();
               }catch (IOException e){
                   e.printStackTrace();
               }
            }
        }
    }
}

image.pngimage.png老师为什么在我第二次运行以后,在里面输入ip地址跟端口以为什么会报空指针异常啊,而且这个空指针异常不是这个程序里面的事这个程序里面的空指针异常

package com;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

//创建点对点的聊天应用
//创建服务端

/**
 * 发送消息线程
 */
class Send extends Thread{
    private Socket socket;
    public Send(Socket socket){
        this.socket = socket;
    }

    public Send(Socket socket, Scanner scanner) {
    }

    @Override
    public void run() {
      /*  String str = null;
        if (str!=null){
            System.out.println(str.charAt(0));
        }*/
        this.sendMsg();
    }
    /**
     * 发送消息
     */
    private void sendMsg(){
        //创建Scanner对象
        try(Scanner scanner = new Scanner(System.in);
            //创建向对方输出消息的流对象
            PrintWriter pw = new PrintWriter(this.socket.getOutputStream());){

            while(true){
                String msg = scanner.nextLine();
                pw.println(msg);
                pw.flush();
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

/**
 * 接收消息的线程
 */
class Receive extends Thread{
    private Socket socket;
    public Receive(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        this.receiveMsg();
    }
    /**
     * 用于接收对方消息的方法
     */
    private void receiveMsg(){
        //创建用于接收对方发送消息的流对象
        try(BufferedReader br = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));){

            while(true){
                String msg = br.readLine();
                System.out.println("他说:"+msg);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}
public class ChatSocketServer {
    public static void main(String[] args) {

        try(ServerSocket serverSocket = new ServerSocket(8080);){
            System.out.println("服务端启动,等待连接。。。。。");
            Socket socket = serverSocket.accept();
            System.out.println("连接成功!");
            new Send(socket).start();
            new Receive(socket).start();
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}


JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程 490楼

package com;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

//创建点对点的聊天应用
//创建服务端

/**
 * 发送消息线程
 */
class Send extends Thread{
    private Socket socket;
    public Send(Socket socket){
        this.socket = socket;
    }

    public Send(Socket socket, Scanner scanner) {
    }

    @Override
    public void run() {
        this.sendMsg();
    }
    /**
     * 发送消息
     */
    private void sendMsg(){
        //创建Scanner对象
        try(Scanner scanner = new Scanner(System.in);
            //创建向对方输出消息的流对象
            PrintWriter pw = new PrintWriter(this.socket.getOutputStream());){

            while(true){
                String msg = scanner.nextLine();
                pw.println(msg);
                pw.flush();
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

/**
 * 接收消息的线程
 */
class Receive extends Thread{
    private Socket socket;
    public Receive(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        this.receiveMsg();
    }
    /**
     * 用于接收对方消息的方法
     */
    private void receiveMsg(){
        //创建用于接收对方发送消息的流对象
        try(BufferedReader br = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));){

            while(true){
                String msg = br.readLine();
                System.out.println("他说:"+msg);
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}
public class ChatSocketServer {
    public static void main(String[] args) {

        try(ServerSocket serverSocket = new ServerSocket(8888);){
            System.out.println("服务端启动,等待连接。。。。。");
            Socket socket = serverSocket.accept();
            System.out.println("连接成功!");
            new Send(socket).start();
            new Receive(socket).start();
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

image.png老师为啥我这边连接成功以后会显示我上面这个代码的36,27行有空指针异常呢,不知道怎么处理

JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程 491楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程 492楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/反射技术 495楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637