java线程并发代码 java多线程并发编程
java线程的经典代码
package threadgroup;
我们拥有十多年网页设计和网站建设经验，从网站策划到网站制作，我们的网页设计师为您提供的解决方案。为企业提供成都网站设计、成都网站建设、微信开发、微信小程序、手机网站制作、成都h5网站建设、等业务。无论您有什么样的网站设计或者设计方案要求，我们都将富于创造性的提供专业设计服务并满足您的需求。
class ThreadDemo3 extends Thread {
private String name;
private int delay;
public ThreadDemo3(String sname, int i_delay) {
name = sname;
delay = i_delay;
}
public void run() {
try {
sleep(delay);
} catch (InterruptedException e) {
}
System.out.println("多线程测试！\n" + name + "\n" + delay);
}
}
public class testMyThread {
public static void main(String[] args) {
ThreadDemo3 th1,th2,th3;
th1 = new ThreadDemo3("线程1", (int) (Math.random() * 900));
th2 = new ThreadDemo3("线程2", (int) (Math.random() * 900));
th3 = new ThreadDemo3("线程3", (int) (Math.random() * 900));
th1.start();
th2.start();
th3.start();
}
}
package threadgroup;
public class threadDemo {
public static void main(String[] args) {
Thread t = Thread.currentThread();
t.setName("你好吗？");
System.out.println("正在进行的Thread是：" + t);
try {
for (int i = 0; i 5; i++) {
System.out.println("我不叫穆继超" + i);
Thread.sleep(3000);
}
} catch (Exception e) {
// TODO: handle exception
System.out.println("Thread has wrong" + e.getMessage());
}
}
}
package threadgroup;
public class threadDemo2 implements Runnable {
public threadDemo2() {
Thread t1 = Thread.currentThread();
t1.setName("第一个主进程");
System.out.println("正在运行" + t1);
Thread t2 = new Thread(this, "");
System.out.println("在创建一个进程");
t2.start();
try {
System.out.println("使他进入第一个睡眠状态");
Thread.sleep(2000);
} catch (InterruptedException e) {
System.out.println("Thread has wrong" + e.getMessage());
}
System.out.println("退出第一个进程");
}
public void run() {
try {
for (int i = 0; i 5; i++) {
System.out.println("进程" + i);
Thread.sleep(3000);
}
} catch (InterruptedException e) {
// TODO: handle exception
System.out.println("Thread has wrong" + e.getMessage());
}
System.out.println("退出第二个进程");
}
public static void main(String[] args) {
new threadDemo2();
}
}
java实现两个线程,一个打印奇数,一个打印偶数,这两个线程如何并发执行？
package test;
public class Test33{
private static int state = 1;
private static int num1 = 1;
private static int num2 = 2;
public static void main(String[] args) {
final Test33 t = new Test33();
new Thread(new Runnable() {
@Override
public void run() {
while(num1100){
//两个线程都用t对象作为锁，保证每个交替期间只有一个线程在打印
synchronized (t) {
// 如果state!=1, 说明此时尚未轮到线程1打印, 线程1将调用t的wait()方法, 直到下次被唤醒
if(state!=1){
try {
t.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// 当state=1时, 轮到线程1打印5次数字
for(int j=0; j1; j++){
System.out.println(num1);
num1 += 2;
}
// 线程1打印完成后, 将state赋值为2, 表示接下来将轮到线程2打印
state = 2;
// notifyAll()方法唤醒在t上wait的线程2, 同时线程1将退出同步代码块, 释放t锁
t.notifyAll();
}
}
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
while(num2100){
synchronized (t) {
if(state!=2){
try {
t.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
for(int j=0; j1; j++){
System.out.println(num2);
num2 += 2;
}
state = 1;
t.notifyAll();
}
}
}
}).start();
}
}
java多线程并发的问题
回答这个问题需要先弄清楚线程的概念和线程的生命周期。
线程：是指程序代码的一次执行，是动态的过程。楼主在定义OneTh这个实现Runnable接口类的时候肯定复写了他的run()方法。onet1和onet2是两个线程，也就是说虽然他们的run()方法相同，但是是执行了两次的。
计算机中CPU的调度过程：现在的电脑看上去能同时实现多任务，像是一边上QQ，一边听音乐，还可以一边上网。但计算机中的CPU只有一个，它没有分身术，不可能真正意义上实现同时运行这么多程序。而是采用了一种时间片轮转的方式，为每个应用程序赋予极短的时间，然后高速的在不同的程序间切换，至于每次切换到那个程序，这个要由CPU和线程的优先级来决定。
线程的生命周期：创建时是初始化了这个线程，调用start方法时，是让这个线程进入了可运行状态，注意是可运行，不是正在运行。就像上面说的，在某一时刻CPU具体要运行谁是由CPU和线程的优先级决定的。当线程被CPU运行时，就会开始执行run方法，但可能执行到一半时，CPU又被其他可运行线程抢走，而只能暂停执行。
JAVA程序线程的运行:在我们使用java命令来运行程序时，这时候已经开始了两个线程，一个是main()方法的线程，一个是垃圾回收的线程。当楼主调用start方法开启另外两个线程时。这时候由于CPU来决定运行哪个线程。所以虽然noet1是先开启的，但在执行noet1时，CPU可能又去跑去执行main线程了，然后就会开启onet2.
还有我觉得主线程结束了，只不过其他两个线程仍在继续运行。所以会打印出结果。
楼主如果还有什么不明白的话可以继续问或者相互讨论。
java 多线程并发请求数据，只要有一条线程获得数据，则其他线程终止运行，并打印出获得的数据
这边我写了一个例子，两个线程同时获取随机数，当获取的值为68的时候则停止所有进程。
这是目录结构：MyThreadOne和MyThreadTwo是两个线程，TestMain是主函数，MyThread继承Thread类。
MyThread.java
package com.xsx.test;
public class MyThread extends Thread {
public void stopThread() {}
}
MyThreadOne.java
package com.xsx.test;
import java.util.Random;
public class MyThreadOne extends MyThread{
private boolean isOK = true;
Random random = new Random();//演示
public void stopThread() {
this.isOK = false;
}
@Override
public void run() {
while(isOK) {
int x = random.nextInt(10000);
System.out.println("Thread One: " + x);
if(x == 68) {
TestMain.stopAll();
System.out.println("My Value is " + x);
break;
}
}
//这边你结合自己的逻辑来写，总之，是通过isOK来控制线程的
}
}
MyThreadTwo.java
package com.xsx.test;
import java.util.Random;
public class MyThreadTwo extends MyThread {
private boolean isOK = true;
Random random = new Random();//演示
public void stopThread() {
this.isOK = false;
}
@Override
public void run() {
while(isOK) {
int x = random.nextInt(10000);
System.out.println("Thread Two: " + x);
if(x == 68) {
TestMain.stopAll();
System.out.println("My Value is " + x);
break;
}
}
}
}
TestMain.java
package com.xsx.test;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
public class TestMain {
public static MapString, MyThread threadPool = new HashMapString, MyThread();//定义一个线程池
/***
* 终止所有线程
*/
public static void stopAll() {
IteratorMyThread threads = threadPool.values().iterator();
while(threads.hasNext()) {
threads.next().stopThread();
}
threadPool.clear();
}
public static void main(String[] args) {
//实例化两个线程获取到随机数为68时就停止进程，并输出
MyThread thread1 = new MyThreadOne();//实例化线程1
MyThread thread2 = new MyThreadTwo();//实例化线程2
threadPool.put("thread1", thread1);//将线程1放入线程池中
threadPool.put("thread2", thread2);//将线程2放入线程池中
thread1.start();//运行
thread2.start();
}
}
项目已经打包上传
网站名称：java线程并发代码 java多线程并发编程
路径分享：http://cdiso.cn/article/doohgoh.html
