public class ThreadsTest {
public static void main(String[] args) {
Threads tsa=new Threads();
Threads tss=new Threads();
Threads tsd=new Threads();
Threads tsf=new Threads();
Threads tsg=new Threads();
Thread ts1=new Thread(tsa, "线程1");
Thread ts2=new Thread(tss, "线程2");
Thread ts3=new Thread(tsd, "线程3");
Thread ts4=new Thread(tsf, "线程4");
Thread ts5=new Thread(tsg, "线程5");
ts1.start();
ts2.start();
ts3.start();
ts4.start();
ts5.start();
}
}
package com.huadian.bean;
public class Threads implements Runnable{
private int str=5;
public Threads(int str) {
super();
this.str = str;
}
public Threads() {
super();
}
@Override
public void run() {
synchronized (Threads.class) {
for(int i=0;i<str;i++){
System.out.println(Thread.currentThread().getName()+"___"+i);
if(i==3){
try {
System.out.println(Thread.currentThread().getName()+"___"+"休息休息-----------------------------");
Thread.sleep(1000);
// Threads.class.notifyAll();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
}
package com.huadian.bean;
public class Threads implements Runnable{
private Integer i=5;
public Threads(int i) {
super();
this.i = i;
}
public Threads() {
super();
}
@Override
public void run() {
while(i>0){
synchronized (i) {
System.out.println(Thread.currentThread().getName()+"___"+i);
/*加上这里的代码就有重复数
* if(i==3){
try {
System.out.println(Thread.currentThread().getName()+"___"+"休息休息-----------------------------"+i);
Thread.sleep(5000);
// Threads.class.notifyAll();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}*/
i--;
}
}
}
}
好了
结果
线程1___0
线程1___1
线程1___2
线程1___3
线程1___休息休息-----------------------------
线程1___4
线程5___0
线程5___1
线程5___2
线程5___3
线程5___休息休息-----------------------------
线程5___4
线程4___0
线程4___1
线程4___2
线程4___3
线程4___休息休息-----------------------------
线程4___4
线程3___0
线程3___1
线程3___2
线程3___3
线程3___休息休息-----------------------------
线程3___4
线程2___0
线程2___1
线程2___2
线程2___3
线程2___休息休息-----------------------------
线程2___4
是不是锁错了？
在线等
原来是每次都new 了一下传进去的都是新的对象才重复执行的
package st.filetest;
public class Threads implements Runnable{
private Integer i=5;
public Threads(int i) {
super();
this.i = i;
}
public Threads() {
super();
}
@Override
public void run() {
while(true){
synchronized (Threads.class) {
for(int i=0;;i++){//==这里改了？
System.out.println(Thread.currentThread().getName()+"___"+i);
if(i==3){
try {
System.out.println(Thread.currentThread().getName()+"___"+"休息休息-----------------------------");
Thread.sleep(1000);
// Threads.class.notifyAll();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}
}
//兄弟，你的代码，没有问题，也没锁错。是你让的线程都有结束条件。你把这里改下，也是vok的： for(int i=0;;i++){//==这里改了？
这几个线程都跑自己的新对象，互相没有关系，各自执行自己的代码，自己的变量