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

问题点:为什么消费者会乱序呢,不是同步类吗?



 商品类:

package cn.sxt.thread9;

public class Goods {
	private String name;
	private String brand;
	public Goods() {
		super();
		// TODO Auto-generated constructor stub
	}
	public Goods(String name, String brand) {
		super();
		this.name = name;
		this.brand = brand;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getBrand() {
		return brand;
	}
	public void setBrand(String brand) {
		this.brand = brand;
	}


}

 生产者:

package cn.sxt.thread9;

public class Producer implements Runnable {
	private Goods goods;
	private int i;
	public Producer(Goods goods){
		this.goods = goods;
	}

	@Override
	public void run() {
		//生产商品
		for(int i=0;i<10;i++){
			if(i%2!=0){				
				this.get("小馒头","旺仔");		
				
			}else{
				this.get("矿泉水","娃哈哈");			
		   }
		   }		
	}
	
	public synchronized void get(String name,String brand){
		goods.setName(name);			
			try {
				Thread.sleep(300);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			goods.setBrand(brand);
			
		
		System.out.println("生产者线程生产了:"+goods.getBrand()+"--------"+goods.getName());
		
	}



}

 消费者:

package cn.sxt.thread9;

public class Consumer implements Runnable {
	private Goods goods;
	public Consumer(Goods goods){
		this.goods = goods;
	}

	@Override
	public void run() {
		// 获取商品
		for(int i=0;i<10;i++){
			this.get();
	
		
	}
	}
	public synchronized void get(){
		try {
			Thread.sleep(300);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println("-----消费者线程取得了"+goods.getBrand()+"---------"+goods.getName());
	}



}

 测试类

package cn.sxt.thread9;

public class TestGoods {
	
	public static void main(String[] args){
		Goods g= new Goods();
		Thread t = new Thread(new Producer(g));
		Thread t1 = new Thread(new Consumer(g));
		t.start();
		t1.start();
		
	}

}

image.png

源代码

MyThread.rar


JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术(旧) 3902楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 3904楼

问题点:当对象都不序列化时程序报错NotSerializableException


Student类

package cn.sxt.reader3;



public class Student{
	/**
	 * 
	 */
	private static final long serialVersionUID = -5066871014990334067L;
	private String name;
	private int age;
	public static String schoolName;//学校名称
	//private transient String pwd;//属性的值将不再被序列化
	public Student() {
		super();
		// TODO Auto-generated constructor stub
	}
	public Student(String name, int age) {
		super();
		this.name = name;
		this.age = age;
		
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public int getAge() {
		return age;
	}
	public void setAge(int age) {
		this.age = age;
	}

	@Override
	public String toString() {
		return "Student [name=" + name + ", age=" + age +   "]"+"schoolName="+schoolName;
	}

}


Classes类

package cn.sxt.reader3;


import java.util.ArrayList;
public class Classes  {
	/**
	 * 
	 */
	private static final long serialVersionUID = -5412831389061890039L;
	private String className;
	private ArrayList<Student> al;
	
	public String getClassName() {
		return className;
	}
	public void setClassName(String className) {
		this.className = className;
	}
	public ArrayList<Student> getAl() {
		return al;
	}
	public void setAl(ArrayList<Student> al) {
		this.al = al;
	}
	
	
	public Classes(String className, ArrayList<Student> al) {
		super();
		this.className = className;
		this.al = al;
		
	}
	public Classes() {
		super();
		// TODO Auto-generated constructor stub
	}

}


测试类

package cn.sxt.reader3;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.ArrayList;

public class TestClasses {
	public static void main(String[] args){
		write();
		//read();
	}
	
	public static void write(){
	ArrayList<Student> al = new ArrayList<Student>();
	al.add(new Student("marray",20));
	al.add(new Student("lili",16));
	al.add(new Student("jack",30));
	Classes cl = new Classes("jn1001",al);
	ObjectOutputStream oos=null;
	try {
		oos = new ObjectOutputStream(new FileOutputStream("D:\\classes.txt"));
		oos.writeObject(cl);
	} catch (FileNotFoundException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (IOException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	}finally{
	if(oos!=null){
		try {
			oos.close();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	}
	}
	public static void read(){
		ObjectInputStream ois=null;
		try {
			ois = new ObjectInputStream(new FileInputStream("D:\\classes.txt"));
			Classes cl = (Classes) ois.readObject();
			System.out.println(cl.getClassName()+"\t"+cl.getAl());
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
		if(ois!=null){
			try {
				ois.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		}
	}
	

}


运行结果

image.png


程序源文件

MyIoDemo.rar


JAVA 全系列/第二阶段:JAVA 基础深化和提高/IO 流技术(旧) 3910楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 3912楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术(旧) 3914楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

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