会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132452个问题

老师你好,请问我的代码输出结果总是1、2 然后就进行不下去了,我把判断条件改为count%2==0输出就只有个1,也进行不下去了;到底哪里出了问题:

1、打印机类

package XCtest;
//创建实体类:实现两种打印方法:12A 34B 56C
//创建代理类
//多线程测试
public class Printer {
	private int count=1;//第一步修改变量为2
	
	//数字打印方法
	public  synchronized void print(int num) {
		if(count%3==0) {
			try {
				super.wait();
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
			
		
		System.out.println(num);//1.输出1,
		count++;//1.count变为2
		
		super.notifyAll();
		}
		
		
//第二组数字打印方法
	public synchronized void pirnt(int Num2) {
		
		if(count%3!=0) {
			
			try {
			super.wait();//当count为2时,此线程仍然等待中
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
		System.out.println(Num2);
		count++;
		super.notifyAll();
		
		
	}
}

2、第一组数字线程

package XCtest;

public class NumXC implements Runnable{
	@SuppressWarnings("unused")
	private Printer printer;
	public NumXC(Printer print) {
		this.printer=print;
	}
	@Override
	public void run() {
		// TODO Auto-generated method stub
		for(int i=1;i<=10;i++) {
			printer.print(i);
		}
		

}
}

3、第二组数字线程

package XCtest;

public class Num2XC implements Runnable{
		@SuppressWarnings("unused")
		private Printer printer;
		public Num2XC(Printer print) {
			this.printer=print;
		}
		@Override
		public void run() {
			// TODO Auto-generated method stub
			for(int j=20;j<=30;j++) {
				printer.print(j);
			}
	}
}

4、测试类

package XCtest;

public class XCtest02 {
	public static void main(String[] args) {
		Printer p=new Printer();
		NumXC n=new NumXC(p);
		Num2XC c=new Num2XC(p);
		Thread t1=new Thread(n);
		Thread t2=new Thread(c);
		t1.start();
		t2.start();//测试结果产生了死锁?
	}
}

测试结果:

image.png


JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术(旧) 1381楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/智能电话本项目实战 1386楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器 1387楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程 1389楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器 1390楼

image.png

老师明明显示连接成功了怎么还会报错呀这是代码

package com.bzsxt;

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(){
        PrintWriter pw = null;
        try{
            //创建向对方输出消息的对象流
            pw = new PrintWriter(this.socket.getOutputStream());
            while(true){
                String msg = scanner.nextLine();
                pw.println(msg);
                pw.flush();
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally{
            if (scanner != null){
                scanner.close();
            }
            if (pw != null){
                pw.close();
            }
            if (this.socket != null){
                try {
                    this.socket.close();
                } catch (IOException 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(){
        BufferedReader br = null;
        try{
            //创建用于接收对方消息的流对象
            br = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
            while(true){
                String msg = br.readLine();
                System.out.println("他说:"+msg);
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            if (br != null){
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (this.socket != null){
                try {
                    this.socket.close();
                } catch (IOException 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]));
                System.out.println("连接成功!");
            }else{
                //启动客户端
                socket = new Socket(arr[0],Integer.parseInt(arr[1]));
                System.out.println("连接成功!");
            }
            //启动发送消息的线程
            new Send1(socket,scanner).start();
            //启动接收消息的线程
            new Receive1(socket).start();
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            if (serverSocket != null){
                try {
                    serverSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}


JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程(旧) 1391楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术(旧) 1392楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程(旧) 1393楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 1394楼


import java.io.*;
import java.util.*;

public class Operate {
    private List<Person> list;
    public Operate(){
        this.list=new ArrayList<>();
    }
    public File dhb =new File("d:/智能电话本.txt");
    /**
     * 实现电话本存储功能
     */
     public void cunchu(List p){
         ObjectOutputStream oos =null;
         try {
             oos = new ObjectOutputStream(new BufferedOutputStream(new FileOutputStream(dhb)));
             oos.writeObject(p);
             oos.flush();
         }catch (Exception e){
             e.printStackTrace();
         }finally {
             try {
                 if (oos!=null){
                     oos.close();
                 }
             }catch (Exception e){
                 e.printStackTrace();
             }
         }
     }
    /**
     * 实现电话本的读取功能
     */
    public void duqv(){
        File a = new File("d:/智能电话本.txt");
        ObjectInputStream ois= null;
        try {
            ois = new ObjectInputStream(new BufferedInputStream(new FileInputStream(a)));
            List list2 = (List) ois.readObject();
            System.out.println("执行读取功能");
            list.addAll(list2);

        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                if(ois!=null){
                    ois.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }
        }

    }
    /**
     * addLogic() 用户添加记录业务逻辑控制
     */
    public void addLogic(){
        Menu menu = new Menu();
        TelNoteRegex telNoteRegex = new TelNoteRegex();
        while (true){
            menu.addMenu();
            int input = telNoteRegex.menuItemValidate(1,3);
            switch (input){
                case 1:
                    this.addOperation();
                    break;
                case 2:
                    this.showAll();
                    break;
                case 3:
                    return;

            }
        }

    }

    /**
     * searchLogic() 用户查询记录业务逻辑控制
     */
    public void serchLogic(){
        Menu menu = new Menu();
        TelNoteRegex telNoteRegex = new TelNoteRegex();
        while (true){
            menu.searchMenu();
            int input = telNoteRegex.menuItemValidate(1,7);
            switch (input){
                case 1:
                    this.searchByName();
                    break;
                case 2:
                    this.searchByAge();
                    break;
                case 3:
                    this.searchBySex();
                    break;
                case 4:
                    this.searchByTelNum();
                    break;
                case 5:
                    this.searchByAdd();
                    break;
                case 6:
                    this.showAll();
                    break;
                case 7:
                    return;
            }
        }
    }

    /**
     * modifyLogic() 修改记录业务逻辑控制
     */
    public void modifyLogic(){
        Menu menu = new Menu();
        TelNoteRegex telNoteRegex=new TelNoteRegex();
        while (true){
            menu.modifyMenu();
            int input = telNoteRegex.menuItemValidate(1,3);
            switch (input){
                case 1:
                    this.showAll();
                    break;
                case 2:
                    this.modifyOperation();
                    break;
                case 3:
                    return;
            }
        }

    }

    /**
     * deleteLogic() 删除记录业务逻辑控制
     */
    public void  deleteLogic(){
        Menu menu = new Menu();
        TelNoteRegex telNoteRegex=new TelNoteRegex();
        while (true) {
            menu.deleteMenu();
            int input = telNoteRegex.menuItemValidate(1,4);
            switch (input){
                case 1:
                    this.showAll();
                    break;
                case 2:
                    this.deleteOperation();
                    break;
                case 3:
                    this.deleteAllOperation();
                    break;
                case 4:return;
            }
        }
    }
    /**
     * orderLogic() 排序记录业务逻辑控制
     */
    public void orderLogic(){
        Menu menu = new Menu();
        TelNoteRegex telNoteRegex=new TelNoteRegex();
        while (true){
            menu.orderMenu();
            int input = telNoteRegex.menuItemValidate(1,5);
            switch (input){
                case 1:
                    this.orderName();
                    break;
                case 2:
                    this.orderAge();
                    break;
                case 3:
                    this.orderSex();
                    break;
                case 4:
                    this.showAll();
                    break;
                case 5:
                    return;
            }
        }
    }
    /**
     * addOperation () 添加新记录信息
     */
    public void  addOperation(){
       TelNoteRegex telNoteRegex= new TelNoteRegex();
       String name = telNoteRegex.nameValidate();
       String age = telNoteRegex.ageValidate();
       String sex = telNoteRegex.sexValidate();
       String telnum = telNoteRegex.telNumValidate();
       String address = telNoteRegex.addressValidate();
       Person person = new Person(name,age,sex,telnum,address);
       list.add(person);
       person.setId(this.list.size());
       cunchu(this.list);


    }
    /**
     * showAll() 查询全部记录
     */
    public void showAll(){
        int size = list.size();
        if (size==0){
            System.out.println("没有任何记录");
        }else {
            for (Person per:list){
                System.out.println(per);
            }
        }

    }
    /**
     * searchByName() 按姓名查询记录
     */
    public void searchByName(){
        if (list.size()==0){
            System.out.println("无任何记录");
            return;
        }
        TelNoteRegex telNoteRegex= new TelNoteRegex();
        String name = telNoteRegex.nameValidate();
        boolean flag = true;
        for(int i = 0 ;i<list.size();i++){
            if (name.equals(list.get(i).getName())){
                System.out.println(list.get(i));
                flag=false;

            }
        }
        if (flag){
            System.out.println("没有该记录");
        }
    }
    /**
     * searchByAge() 按年龄查询记录
     */
    public void searchByAge(){
        if (list.size()==0){
            System.out.println("无任何记录");
            return;
        }
        TelNoteRegex telNoteRegex= new TelNoteRegex();
        String age = telNoteRegex.ageValidate();
        boolean flag = true;
        for (int i = 0;i<list.size();i++){
            if (age.equals(list.get(i).getAge())){
                System.out.println(list.get(i));
                flag=false;
            }
        }
        if (flag){
            System.out.println("没有此纪录");
        }
    }
    /**
     * searchBySex() 按性别查询记录
     */
    public void searchBySex(){
        if (list.size()==0){
            System.out.println("无任何记录");
            return;
        }
        TelNoteRegex telNoteRegex= new TelNoteRegex();
        String sex = telNoteRegex.sexValidate();
        boolean flag = true;
        for (int i = 0;i<list.size();i++){
            if (sex.equals(list.get(i).getSex())){
                System.out.println(list.get(i));
                flag=false;
            }
        }
        if (flag){
            System.out.println("没有此纪录");
        }
    }
    /**
     * searchByTelNum() 按电话号码查询记录
     */
    public void searchByTelNum(){
        if (list.size()==0){
            System.out.println("无任何记录");
            return;
        }
        TelNoteRegex telNoteRegex= new TelNoteRegex();
        String telnum = telNoteRegex.telNumValidate();
        boolean flag = true;
        for (int i = 0;i<list.size();i++){
            if (telnum.equals(list.get(i).getTelnum())){
                System.out.println(list.get(i));
                flag=false;
            }
        }
        if (flag){
            System.out.println("没有此纪录");
        }
    }
    /**
     * searchByAdd() 按地址查询记录
     */
    public void searchByAdd(){
        if (list.size()==0){
            System.out.println("无任何记录");
            return;
        }
        TelNoteRegex telNoteRegex= new TelNoteRegex();
        String address = telNoteRegex.addressValidate();
        boolean flag = true;
        for (int i = 0;i<list.size();i++){
            if (address.equals(list.get(i).getAddress())){
                System.out.println(list.get(i));
                flag=false;
            }
        }
        if (flag){
            System.out.println("没有此纪录");
        }
    }
    /**
     * modifyOperation() 修改指定记录
     */
    public void modifyOperation(){
        TelNoteRegex telNoteRegex = new TelNoteRegex();
        Menu menu = new Menu();
        if (list.size()==0){
            System.out.println("当前无任何记录");
            return;
        }
        System.out.println("请输入您想修改的序号:");
        int itnum = telNoteRegex.menuItemValidate(1,this.list.size());
        System.out.println("即将修改的数据如下:");
        System.out.println(list.get(itnum-1));
        menu.subModifyMenu();
        int input2 = telNoteRegex.menuItemValidate(1,6);
        while (true){
            switch (input2){
                case 1:
                    String name = telNoteRegex.nameValidate();
                    this.list.get(itnum-1).setName(name);
                    System.out.println("记录修改成功");
                    System.out.println("当前数据为:"+list.get(itnum-1));
                    cunchu(this.list);
                    return;
                case 2:
                    String age = telNoteRegex.ageValidate();
                    this.list.get(itnum-1).setAge(age);
                    System.out.println("记录修改成功");
                    System.out.println("当前数据为:"+list.get(itnum-1));
                    cunchu(this.list);
                    return;
                case 3:
                    String sex = telNoteRegex.sexValidate();
                    this.list.get(itnum-1).setSex(sex);
                    System.out.println("记录修改成功");
                    System.out.println("当前数据为:"+list.get(itnum-1));
                    cunchu(this.list);
                    return;
                case 4:
                    String telnum = telNoteRegex.telNumValidate();
                    this.list.get(itnum-1).setTelnum(telnum);
                    System.out.println("记录修改成功");
                    System.out.println("当前数据为:"+list.get(itnum-1));
                    cunchu(this.list);
                    return;
                case 5:
                    String adress = telNoteRegex.addressValidate();
                    this.list.get(itnum-1).setAddress(adress);
                    System.out.println("记录修改成功");
                    System.out.println("当前数据为:"+list.get(itnum-1));
                    cunchu(this.list);
                    return;
                case 6:return;
            }
        }

    }
    /**
     * deleteOperation() 删除指定记录
     */
    public void deleteOperation(){
        TelNoteRegex telNoteRegex=new TelNoteRegex();
        Scanner scanner=new Scanner(System.in);
        if(this.list.size()==0){
            System.out.println("当前无任何记录!");
            return;
        }
        System.out.println("请输入您想删除的记录序号:");
        int itnum = telNoteRegex.menuItemValidate(1,this.list.size());
        System.out.println("即将删除如下数据:");
        System.out.println(this.list.get(itnum-1));
        System.out.println("是否确认删除?");
        String input = scanner.nextLine();
        if (input.equals("是")){
            this.list.remove(itnum-1);
            for (int i = 0;i<list.size();i++){
                list.get(i).setId(i+1);
            }
            System.out.println("数据已成功删除!");
            cunchu(this.list);
            return;
        }else {
            System.out.println("已取消删除");
            cunchu(this.list);
            return;
        }

    }
    /**
     * deleteAllOperation() 删除全部记录
     */
    public void deleteAllOperation(){
        if (this.list.size()==0){
            System.out.println("当前无任何记录!");
            return;
        }
        Scanner scanner=new Scanner(System.in);
        System.out.println("即将删除全部记录,是否继续?");
        String input = scanner.nextLine();
        if (input.equals("是")){
            this.list.clear();
            System.out.println("数据已全部删除");
            cunchu(this.list);
            return;
        }else {
            System.out.println("已取消删除");
            cunchu(this.list);
            return;
        }
    }
    /**
    *orderName() 按用户姓名排序记录
    */
    public void orderName(){

        if (this.list.size()==0){
            System.out.println("当前无任何记录!");
            return;
        }
        Collections.sort(this.list, new OrderByName());
        for (int i = 0 ;i<list.size();i++){
            this.list.get(i).setId(i+1);
            System.out.println("排序成功");
            cunchu(this.list);
            for (Person per:list) {
                System.out.println(per);
            }
            return;
        }


    }
    /**
     * orderAge() 按用户年龄排序记录
     */
    public void orderAge(){
        if (this.list.size()==0){
            System.out.println("当前无任何记录!");
            return;
        }
        Collections.sort(this.list, new OrderByAge());
        for (int i = 0 ;i<list.size();i++){
            this.list.get(i).setId(i+1);
            System.out.println("排序成功");
            cunchu(this.list);
            for (Person per:list) {
                System.out.println(per);
            }
            return;
        }
    }
    /**
     * orderSex() 按用户性别排序记录
     */
    public void orderSex(){
        if (this.list.size()==0){
            System.out.println("当前无任何记录!");
            return;
        }
        Collections.sort(this.list, new OrderBySex());
        for (int i = 0 ;i<list.size();i++){
            this.list.get(i).setId(i+1);
            System.out.println("排序成功");
            cunchu(this.list);
            for (Person per:list) {
                System.out.println(per);
            }
            return;
        }
    }
    /**
     * 按照姓名排序的比较器
     */
    class OrderByName implements Comparator<Person>{

        @Override
        public int compare(Person o1, Person o2) {
            return o1.getName().compareTo(o2.getName());
        }
    }
    /**
     * 按照年龄排序的比较器
     */
    class OrderByAge implements Comparator<Person>{

        @Override
        public int compare(Person o1, Person o2) {
            return o1.getAge().compareTo(o2.getAge());
        }
    }
    /**
     * 按照性别排序的比较器
     */
    class OrderBySex implements Comparator<Person>{

        @Override
        public int compare(Person o1, Person o2) {
            return o1.getSex().compareTo(o2.getSex());
        }
    }

}

在Operate类中建立了存储和读取的方法,之后在下面每一个涉及电话本改动的地方都调用了一次存储方法,保证添加,修改,排序,删除都能正常存储到文件中,但是感觉这样比较麻烦,不知道更好的解决方案是什么,而且我在用IO流的时候,直接用的是list对象,因为忘了怎么把list重新转回Person对象了,不知道这样是否合理,麻烦老师给看一看,



JAVA 全系列/第二阶段:JAVA 基础深化和提高/IO 流技术(旧) 1395楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

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