请教一个多线程的问题# Java - 爪哇娇娃
v*a
1 楼
我想从h4转f1，不知道要多久，老公h1下个月回国，
如果这样，是不是，我的申请材料递交上去，就可以了？！不管h1在不在美国？
如果不行，就不要申请好了
如果这样，是不是，我的申请材料递交上去，就可以了？！不管h1在不在美国？
如果不行，就不要申请好了
n*1
2 楼
自己练习写了一个多线程读一个字符串，但是没法退出，想请教两个问题
1.这种写法是我自己想出来，有没有更优雅一点的方法呢
2.线程间应该怎么通知结束信号然后退出的？
感觉多线程难用的原因因为需要全部理解才能用好，一个地方没理解好，就用不好
import java.util.Scanner;
import java.util.concurrent.atomic.AtomicInteger;
class Reader implements Runnable {
private int id;
private String[] queue;
private Object lock;
private volatile AtomicInteger index;
private int threads;
private volatile boolean done = false;
public Reader(int id, String[] queue, Object lock, AtomicInteger index,
int threads, Boolean done) {
this.id = id;
this.queue = queue;
this.lock = lock;
this.index = index;
this.threads = threads;
this.done = done;
}
public void run() {
while (!done) {
synchronized (lock) {
while (index.get() % threads != id)
try {
lock.wait();
} catch (Exception e) {
}
System.out.println("The id" + id + ": " + queue[index.get()]
);
if (index.incrementAndGet() == queue.length) {
done = true;
}
lock.notifyAll();
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
public class MultiReading {
public static void main(String[] args) throws InterruptedException {
Scanner scan = new Scanner(System.in);
String line = scan.nextLine();
String words[] = line.split("\s");
Boolean done = false;
Object lock = new Object();
AtomicInteger index = new AtomicInteger(0);
int threads = 3;
for (int i = 0; i < threads; i++) {
new Thread(new Reader(i, words, lock, index, threads, done))
.start();
}
}
}
1.这种写法是我自己想出来，有没有更优雅一点的方法呢
2.线程间应该怎么通知结束信号然后退出的？
感觉多线程难用的原因因为需要全部理解才能用好，一个地方没理解好，就用不好
import java.util.Scanner;
import java.util.concurrent.atomic.AtomicInteger;
class Reader implements Runnable {
private int id;
private String[] queue;
private Object lock;
private volatile AtomicInteger index;
private int threads;
private volatile boolean done = false;
public Reader(int id, String[] queue, Object lock, AtomicInteger index,
int threads, Boolean done) {
this.id = id;
this.queue = queue;
this.lock = lock;
this.index = index;
this.threads = threads;
this.done = done;
}
public void run() {
while (!done) {
synchronized (lock) {
while (index.get() % threads != id)
try {
lock.wait();
} catch (Exception e) {
}
System.out.println("The id" + id + ": " + queue[index.get()]
);
if (index.incrementAndGet() == queue.length) {
done = true;
}
lock.notifyAll();
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
public class MultiReading {
public static void main(String[] args) throws InterruptedException {
Scanner scan = new Scanner(System.in);
String line = scan.nextLine();
String words[] = line.split("\s");
Boolean done = false;
Object lock = new Object();
AtomicInteger index = new AtomicInteger(0);
int threads = 3;
for (int i = 0; i < threads; i++) {
new Thread(new Reader(i, words, lock, index, threads, done))
.start();
}
}
}
p*3
3 楼
看不懂程序，能说说这段程序的目的吗。感觉有点乱七八糟的。抛个砖头，等zhaoce和
二爷
只读为啥要多线程，构造函数咋啥都传进来了，AtomicInteger 不需要volatile修饰吧
，thread创建了咋没东西track，lock.wait后没有double check precondition,为啥要
swallow exception, 为啥要sleep，是不是可以用executionService
可以等都执行完了退出，比如像这样设置个done, 中断可以发interrupt, 线程要加判
断和处理interrupt的逻辑
二爷
只读为啥要多线程，构造函数咋啥都传进来了，AtomicInteger 不需要volatile修饰吧
，thread创建了咋没东西track，lock.wait后没有double check precondition,为啥要
swallow exception, 为啥要sleep，是不是可以用executionService
可以等都执行完了退出，比如像这样设置个done, 中断可以发interrupt, 线程要加判
断和处理interrupt的逻辑
p*2
4 楼
听说现在很少会用java的多线程了，都是用actor，gochannel这些东西，最不济也还有
STM呢。
【在 p*****3 的大作中提到】
: 看不懂程序，能说说这段程序的目的吗。感觉有点乱七八糟的。抛个砖头，等zhaoce和
: 二爷
: 只读为啥要多线程，构造函数咋啥都传进来了，AtomicInteger 不需要volatile修饰吧
: ，thread创建了咋没东西track，lock.wait后没有double check precondition,为啥要
: swallow exception, 为啥要sleep，是不是可以用executionService
: 可以等都执行完了退出，比如像这样设置个done, 中断可以发interrupt, 线程要加判
: 断和处理interrupt的逻辑
s*e
5 楼
go read java concurrency in practice. There are many ways to handle end
signals among the threads. For example, completeService, barrier, latch, etc.
One thing for sure is that you do not want to use raw thread directly for
today unless you have a very good reason.
【在 n******1 的大作中提到】
: 自己练习写了一个多线程读一个字符串，但是没法退出，想请教两个问题
: 1.这种写法是我自己想出来，有没有更优雅一点的方法呢
: 2.线程间应该怎么通知结束信号然后退出的？
: 感觉多线程难用的原因因为需要全部理解才能用好，一个地方没理解好，就用不好
: import java.util.Scanner;
: import java.util.concurrent.atomic.AtomicInteger;
: class Reader implements Runnable {
: private int id;
: private String[] queue;
: private Object lock;
signals among the threads. For example, completeService, barrier, latch, etc.
One thing for sure is that you do not want to use raw thread directly for
today unless you have a very good reason.
【在 n******1 的大作中提到】
: 自己练习写了一个多线程读一个字符串，但是没法退出，想请教两个问题
: 1.这种写法是我自己想出来，有没有更优雅一点的方法呢
: 2.线程间应该怎么通知结束信号然后退出的？
: 感觉多线程难用的原因因为需要全部理解才能用好，一个地方没理解好，就用不好
: import java.util.Scanner;
: import java.util.concurrent.atomic.AtomicInteger;
: class Reader implements Runnable {
: private int id;
: private String[] queue;
: private Object lock;
l*g
6 楼
public void run() {
while (!done) {
synchronized (lock) { while (index.get() % threads != id) try {
lock.wait(); 你就要有一个地方notify()。一旦你进入这里，你下面的notifyAll是永远都到达不了
的，因为你这个事wait forever!
} catch (Exception e) {
}
System.out.println("The id" + id + ": " + queue[index.get()]
);
if (index.incrementAndGet() == queue.length) {
done = true;
}
lock.notifyAll();
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
我给你简单的说一下java线程中wait和sleep的用法。
sleep，顾名思义，就是睡眠，就是让当前线程睡眠一个给定的时间，然后自己继续执
行后面的代码。
wait/notify：一般情况是用来再一个内部条件的变化，会影响外部调用线程堵塞状态
的场景，简单来说，就是race condition，比如，你设计一个pool，一个method是take
，另一个是return，那么这个时候你就要用notify和wait。原因很简单，当take的时候
，如果出现pool没有东西可以给返回，那么就需要wait，你也可以理解成，告诉调用
take方法的线程等一下，而在等的时候，如果，一旦有另一个线程调用return方法还回
来一个item，那么就要呼叫notify或者notifyAll（区别自己花点时间研究），因为你
告诉那个正在等待的线程，”我们有新货了，来拿吧。“
多看点线程的文章，多练习一下比如写一个producer／consumer模式之类的。
while (!done) {
synchronized (lock) { while (index.get() % threads != id) try {
lock.wait(); 你就要有一个地方notify()。一旦你进入这里，你下面的notifyAll是永远都到达不了
的，因为你这个事wait forever!
} catch (Exception e) {
}
System.out.println("The id" + id + ": " + queue[index.get()]
);
if (index.incrementAndGet() == queue.length) {
done = true;
}
lock.notifyAll();
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
我给你简单的说一下java线程中wait和sleep的用法。
sleep，顾名思义，就是睡眠，就是让当前线程睡眠一个给定的时间，然后自己继续执
行后面的代码。
wait/notify：一般情况是用来再一个内部条件的变化，会影响外部调用线程堵塞状态
的场景，简单来说，就是race condition，比如，你设计一个pool，一个method是take
，另一个是return，那么这个时候你就要用notify和wait。原因很简单，当take的时候
，如果出现pool没有东西可以给返回，那么就需要wait，你也可以理解成，告诉调用
take方法的线程等一下，而在等的时候，如果，一旦有另一个线程调用return方法还回
来一个item，那么就要呼叫notify或者notifyAll（区别自己花点时间研究），因为你
告诉那个正在等待的线程，”我们有新货了，来拿吧。“
多看点线程的文章，多练习一下比如写一个producer／consumer模式之类的。
相关阅读
update for cookxml/cookswing/cookswtJava程序员认证模拟题及详细分析(4)Can I use XDoclet and packging in Tomcat帮忙看看. Get context variableHow to write a file to the same directory of the class file?BSF development stopped?海量级数据的算法问题ft, BSF documentation?如何动态改变log4j的log level啊Jar文件中的datajava的进度条中间能够显示进度百分比吗？What xml editor plugin for eclipse?Servlet的IO吞吐瓶颈在哪里？为什么测下来只有3M bytes 左右？请问如何在jbuider里面安装poi?大量文本数据的读取final static constants easy get cached?大侠帮忙看看这个code为什么在jdk1。5下面不能运行Java.Net初学: 我的简单问题, 寻求简单方案help:tomcat5 on FC4再请教一个 编译错误