多线程基础与回调

工作了一年了，一直没怎么多用线程一块，好薄弱,，今天看了看。自己写了个小例子。免的以后忘了。做的主要是线程监控返回值。即不用轮训，和设置变量。让线程通知主类（我做完活东西给你了。）

        直接上代码吧。

 package com.bjz;

/**
 * 实现
 * @author bjz
 *
 */
public interface CallbackListener {
	public void srtartCallbackThread();

	public void print(String returnResult);  //主要实现方法,为什么不红了？？？

}

接口只要是供调用线程的类实现。从而实现线程和调用方法的解耦（ps:线程对主类）

package com.bjz;

public class Reciver implements CallbackListener {
	private String num;
	private int count;

	String result;

	public Reciver(String num, int count) {
		this.num = num;
		this.count = count;
	}

	@Override
	public void srtartCallbackThread() {
		CallbackAndThread callbackAndThread = new CallbackAndThread(num, count);
		callbackAndThread.addList(this);
		new Thread(callbackAndThread).start();
		
	}

	[color=darkred]@Override
	public void print(String returnResult) {
		this.result = returnResult;
		System.out.println(result);
	}[/color]   //主要实现方法,为什么不红了？？？
}

下来就是线程了

package com.bjz;

import java.util.List;
import java.util.ListIterator;
import java.util.Vector;

public class CallbackAndThread implements Runnable {

	private String note;
	private int count;
	private List listenerList = new Vector();

	public CallbackAndThread(String note, int count) {
		this.note = note;
		this.count = count;
	}

	public void addList(CallbackListener listener) {
		listenerList.add(listener);
	}

	public void removeList(CallbackListener listener) {
		listenerList.remove(listener);
	}
[color=darkred]
	public synchronized void returnResult(String note, int count) {
		ListIterator iterator = listenerList.listIterator();
		while (iterator.hasNext()) {
			CallbackListener listener = (CallbackListener) iterator.next();
			StringBuffer sb = new StringBuffer();
			for (int i = 0; i < count; i++) {
				sb.append(note);
			}
			listener.print(sb.toString());
		}
	}[/color]   //主要实现方法,为什么不红了？？？

	@Override
	public void run() {
		returnResult(note, count);
	}
}

package com.bjz;

public class Test {
	public static void main(String[] args) {
		for (int i=0;i<10;i++) {
			Reciver reciver = new Reciver(i+"", 50);
			reciver.srtartCallbackThread();
		}
	}
}

测试类

评论

8 楼 jiangzhoubai 2012-03-29  

lemon_1227 写道

帅哥，那个 addlist，removelist 两个方法，不用加synchronized同步，因为你使用的是Vector，它本身就是线程安全的。

嗯，是的。谢谢拍砖了

7 楼 lemon_1227 2012-03-27  

帅哥，那个 addlist，removelist 两个方法，不用加synchronized同步，因为你使用的是Vector，它本身就是线程安全的。

6 楼 jiangzhoubai 2012-03-27  

lemon_1227 写道

jiangzhoubai 写道

lemon_1227 写道

jiangzhoubai 写道

lemon_1227 写道

兄弟，你写了个么个哦？我看不懂来，给个应用场景啊

1、节省了cpu的计算
2、如果多个对象关注这个线程，可以把自己添加到list中，表明自己关心。

像你说的这样的话，那么CallbackListener.srtartCallbackThread()方法要提供一个传入线程的参数噻。

callbackAndThread.addList(this);

我意思是，你再创建一个CallbackListener，你要把这个对象加入到已有线程中啊，而你给出的srtartCallbackThread()实现中，都是new 一个新线程哦

哦。明白了。 那块确实有点问题，是因为上次去清理电脑，你没给我插风扇的电源，为了测试温度，多跑几个线程这样写的。 后来没有删除。 

这块应该是new CallbackListener 的实现 add到list中。

不管怎么说谢谢兄弟了

5 楼 lemon_1227 2012-03-27  

jiangzhoubai 写道

lemon_1227 写道

jiangzhoubai 写道

lemon_1227 写道

兄弟，你写了个么个哦？我看不懂来，给个应用场景啊

1、节省了cpu的计算
2、如果多个对象关注这个线程，可以把自己添加到list中，表明自己关心。

像你说的这样的话，那么CallbackListener.srtartCallbackThread()方法要提供一个传入线程的参数噻。

callbackAndThread.addList(this);

我意思是，你再创建一个CallbackListener，你要把这个对象加入到已有线程中啊，而你给出的srtartCallbackThread()实现中，都是new 一个新线程哦

4 楼 jiangzhoubai 2012-03-27  

lemon_1227 写道

jiangzhoubai 写道

lemon_1227 写道

兄弟，你写了个么个哦？我看不懂来，给个应用场景啊

1、节省了cpu的计算
2、如果多个对象关注这个线程，可以把自己添加到list中，表明自己关心。

像你说的这样的话，那么CallbackListener.srtartCallbackThread()方法要提供一个传入线程的参数噻。

callbackAndThread.addList(this);

3 楼 lemon_1227 2012-03-27  

jiangzhoubai 写道

lemon_1227 写道

兄弟，你写了个么个哦？我看不懂来，给个应用场景啊

1、节省了cpu的计算
2、如果多个对象关注这个线程，可以把自己添加到list中，表明自己关心。

像你说的这样的话，那么CallbackListener.srtartCallbackThread()方法要提供一个传入线程的参数噻。

2 楼 jiangzhoubai 2012-03-27  

lemon_1227 写道

兄弟，你写了个么个哦？我看不懂来，给个应用场景啊

1、节省了cpu的计算
2、如果多个对象关注这个线程，可以把自己添加到list中，表明自己关心。

1 楼 lemon_1227 2012-03-27  

兄弟，你写了个么个哦？我看不懂来，给个应用场景啊