java中什么是线程同步的,java中什么同步什么是异步分别用在什么地方
老铁们,大家好,相信还有很多朋友对于java中什么是线程同步的和java中什么同步什么是异步分别用在什么地方的相关问题不太懂,没关系,今天就由我来为大家分享分享java中什么是线程同步的以及java中什么同步什么是异步分别用在什么地方的问题,文章篇幅可能偏长,希望可以帮助到大家,下面一起来看看吧!
JAVA中线程同步方法有哪些
JAVA中线程同步方法一般有以下三种:
1 wait方法:
该方法属于Object的方法,wait方法的作用是使得当前调用wait方法所在部分(代码块)的线程停止执行,并释放当前获得的调用wait所在的代码块的锁,并在其他线程调用notify或者notifyAll方法时恢复到竞争锁状态(一旦获得锁就恢复执行)。
调用wait方法需要注意几点:
第一点:wait被调用的时候必须在拥有锁(即synchronized修饰的)的代码块中。
第二点:恢复执行后,从wait的下一条语句开始执行,因而wait方法总是应当在while循环中调用,以免出现恢复执行后继续执行的条件不满足却继续执行的情况。
第三点:若wait方法参数中带时间,则除了notify和notifyAll被调用能激活处于wait状态(等待状态)的线程进入锁竞争外,在其他线程中interrupt它或者参数时间到了之后,该线程也将被激活到竞争状态。
第四点:wait方法被调用的线程必须获得之前执行到wait时释放掉的锁重新获得才能够恢复执行。
2 notify方法和notifyAll方法:
notify方法通知调用了wait方法,但是尚未激活的一个线程进入线程调度队列(即进入锁竞争),注意不是立即执行。并且具体是哪一个线程不能保证。另外一点就是被唤醒的这个线程一定是在等待wait所释放的锁。
notifyAll方法则唤醒所有调用了wait方法,尚未激活的进程进入竞争队列。
3 synchronized关键字:
第一点:synchronized用来标识一个普通方法时,表示一个线程要执行该方法,必须取得该方法所在的对象的锁。
第二点:synchronized用来标识一个静态方法时,表示一个线程要执行该方法,必须获得该方法所在的类的类锁。
第三点:synchronized修饰一个代码块。类似这样:synchronized(obj){//code....}。表示一个线程要执行该代码块,必须获得obj的锁。这样做的目的是减小锁的粒度,保证当不同块所需的锁不冲突时不用对整个对象加锁。利用零长度的byte数组对象做obj非常经济。
Java中线程怎么同步
1、使用线程类自带的join方法,将子线程加入到主线程,在子线程执行完之后,在执行主线程逻辑。
例如
[java]view plaincopy
publicstaticvoidjoinDemo()
throwsInterruptedException
{
System.out.println("=========Testwithjoin=====");
JoinWorkerworker1=newJoinWorker("worker1");
JoinWorkerworker2=newJoinWorker("worker2");
worker1.start();
worker2.start();
worker1.join();
worker2.join();
doSuperWork();
}
2、使用JDK的并发包中的CountDownLatch类,使用CountDownLatch,每个线程调用其countDown方法使计数器-1,主线程调用await方法阻塞等待,直到CountDownLatch计数器为0时继续执行,例如
首先,定义子线程
[java]view plaincopy
staticclassCountDownLatchWorkerextendsThread
{
StringworkerName;
CountDownLatchlatch;
publicCountDownLatchWorker(StringworkerName,CountDownLatchlatch)
{
this.workerName=workerName;
this.latch=latch;
}
publicvoidrun()
{
System.out.println("SubWorker"+workerName+"doworkbeginat"
+sdf.format(newDate()));
newThreadWaitDemo().doSomeWork();//做实际工作
System.out.println("SubWorker"+workerName+"doworkcompleteat"
+sdf.format(newDate()));
latch.countDown();//完成之后,计数器减一
}
}
主线程中调研await方法阻塞等待,直到所有线程完成
[html]view plaincopy
publicstaticvoidcountDownLatchDemo()
throwsInterruptedException
{
System.out.println("=========TestwithCountDownLatch=====");
CountDownLatchlatch=newCountDownLatch(2);
CountDownLatchWorkerworker1=newCountDownLatchWorker("worker1",latch);
CountDownLatchWorkerworker2=newCountDownLatchWorker("worker2",latch);
worker1.start();
worker2.start();
//主线程阻塞等待
latch.await();
doSuperWork();
}
3、使用JDK并发包CyclicBarrier,CyclicBarrier类似于CountDownLatch也是个计数器,不同的是CyclicBarrier的await()方法没被调用一次,计数便会减少1,并阻塞住当前线程。当计数减至0时,阻塞解除,所有在此 CyclicBarrier上面阻塞的线程开始运行。在这之后,如果再次调用 await()方法,计数就又会变成 N-1,新一轮重新开始CyclicBarrier初始时还可带一个Runnable的参数,此Runnable任务在CyclicBarrier的数目达到后,所有其它线程被唤醒前被执行。
示例如下
[java]view plaincopy
publicstaticvoidcyclicBarrierDemo()
throwsInterruptedException,BrokenBarrierException
{
System.out.println("=========TestwithCyclicBarrier=====");
CyclicBarriercb=newCyclicBarrier(2,newRunnable()
{
//将主线程业务放到CyclicBarrier构造方法中,所有线程都到达Barrier时执行
@SuppressWarnings("static-access")
publicvoidrun()
{
newThreadWaitDemo().doSuperWork();
}
});//设定需要等待两个线程
ExecutorServiceexecutor=Executors.newFixedThreadPool(2);
CyclicBarrierWorkerworker1=newCyclicBarrierWorker("worker1",cb);
CyclicBarrierWorkerworker2=newCyclicBarrierWorker("worker2",cb);
executor.execute(worker1);
executor.execute(worker2);
executor.shutdown();
}
4、使用JDK并发包中的Executors框架,ExecutorService的的invokeAll方法调研callable集合,批量执行多个线程,在invokeAll方法结束之后,再执行主线程其他业务逻辑
示例如下
[java]view plaincopy
publicstaticvoidcallableDemo()
throwsInterruptedException
{
System.out.println("=========TestwithCallable=====");
List<Callable<Integer>>callList=newArrayList<Callable<Integer>>();
ExecutorServiceexec=Executors.newFixedThreadPool(2);
//采用匿名内部类实现
callList.add(newCallable<Integer>()
{
publicIntegercall()
throwsException
{
System.out.println("SubWorkerworker1doworkbeginat"+sdf.format(newDate()));
newThreadWaitDemo().doSomeWork();//做实际工作
System.out.println("SubWorkerworker1doworkcompleteat"
+sdf.format(newDate()));
return0;
}
});
callList.add(newCallable<Integer>()
{
publicIntegercall()
throwsException
{
System.out.println("SubWorkerworker2doworkbeginat"+sdf.format(newDate()));
newThreadWaitDemo().doSomeWork();//做实际工作
System.out.println("SubWorkerworker2doworkcompleteat"
+sdf.format(newDate()));
return0;
}
});
exec.invokeAll(callList);
exec.shutdown();
doSuperWork();
}
5、这种过于恶心,只简单说一下方法,主线程创建一个线程List,将每个子线程保存到列表中,然后定期轮询列表中子线程状态,当所有线程都完成之后,再执行主线程逻辑java里同步是什么意思
一般有两种方法同步方法和同步代码块
假设P1、P2是同一个类的不同对象,这个类中定义了以下几种情况的同步块或同步方法,P1、P2就都可以调用它们。
1.把synchronized当作函数修饰符时,示例代码如下:
Public synchronized void methodAAA()
{
//….
}
这也就是同步方法,那这时synchronized锁定的是哪个对象呢?它锁定的是调用这个同步方法对象。也就是说,当一个对象P1在不同的线程中执行这个同步方法时,它们之间会形成互斥,达到同步的效果。但是这个对象所属的Class所产生的另一对象P2却可以任意调用这个被加了synchronized关键字的方法。
上边的示例代码等同于如下代码:
public void methodAAA()
{
synchronized(this)//(1)
{
//…..
}
}
(1)处的this指的是什么呢?它指的就是调用这个方法的对象,如P1。可见同步方法实质是将synchronized作用于object reference。――那个拿到了P1对象锁的线程,才可以调用P1的同步方法,而对P2而言,P1这个锁与它毫不相干,程序也可能在这种情形下摆脱同步机制的控制,造成数据混乱:(
2.同步块,示例代码如下:
public void method3(SomeObject so)
{
synchronized(so)
{
//…..
}
}
这时,锁就是so这个对象,谁拿到这个锁谁就可以运行它所控制的那段代码。当有一个明确的对象作为锁时,就可以这样写程序,但当没有明确的对象作为锁,只是想让一段代码同步时,可以创建一个特殊的instance变量(它得是一个对象)来充当锁:
class Foo implements Runnable
{
private byte[] lock= new byte[0];//特殊的instance变量
Public void methodA()
{
synchronized(lock){//…}
}
//…..
}
注:零长度的byte数组对象创建起来将比任何对象都经济――查看编译后的字节码:生成零长度的byte[]对象只需3条操作码,而Object lock= new Object()则需要7行操作码。
3.将synchronized作用于static函数,示例代码如下:
Class Foo
{
public synchronized static void methodAAA()//同步的static函数
{
//….
}
public void methodBBB()
{
synchronized(Foo.class)// class literal(类名称字面常量)
}
}
代码中的methodBBB()方法是把class literal作为锁的情况,它和同步的static函数产生的效果是一样的,取得的锁很特别,是当前调用这个方法的对象所属的类(Class,而不再是由这个Class产生的某个具体对象了)。
记得在《Effective Java》一书中看到过将 Foo.class和 P1.getClass()用于作同步锁还不一样,不能用P1.getClass()来达到锁这个Class的目的。P1指的是由Foo类产生的对象。
可以推断:如果一个类中定义了一个synchronized的static函数A,也定义了一个synchronized的instance函数B,那么这个类的同一对象Obj在多线程中分别访问A和B两个方法时,不会构成同步,因为它们的锁都不一样。A方法的锁是Obj这个对象,而B的锁是Obj所属的那个Class。
java中什么同步什么是异步分别用在什么地方
java同步指的是synchronized机制,而非synchronized的都是异步,弄懂同步的概念就大致明白了两者的差别。
有关同步:
synchronized用来修饰一个方法或者一个代码块,它用来保证在同一时刻最多只有一个线程执行该段代码。
一、当两个并发线程访问同一个对象object中的这个synchronized(this)同步代码块时,一个时间内只能有一个线程得到执行。另一个线程必须等待当前线程执行完这个代码块以后才能执行该代码块。
二、然而,当一个线程访问object的一个synchronized(this)同步代码块时,另一个线程仍然可以访问该object中的非synchronized(this)同步代码块。
三、尤其关键的是,当一个线程访问object的一个synchronized(this)同步代码块时,其他线程对object中所有其它synchronized(this)同步代码块的访问将被阻塞。
四、第三个例子同样适用其它同步代码块。也就是说,当一个线程访问object的一个synchronized(this)同步代码块时,它就获得了这个object的对象锁。结果,其它线程对该object对象所有同步代码部分的访问都被暂时阻塞。
五、以上规则对其它对象锁同样适用。
示例代码:
public class Thread1 implements Runnable{
public void run(){
synchronized(this){
for(int i= 0; i< 5; i++){
System.out.println(Thread.currentThread().getName()+" synchronized loop"+ i);
}
}
}
public static void main(String[] args){
Thread1 t1= new Thread1();
Thread ta= new Thread(t1,"A");
Thread tb= new Thread(t1,"B");
ta.start();
tb.start();
}
}
结果:
A synchronized loop 0
A synchronized loop 1
A synchronized loop 2
A synchronized loop 3
A synchronized loop 4
B synchronized loop 0
B synchronized loop 1
B synchronized loop 2
B synchronized loop 3
B synchronized loop 4
OK,本文到此结束,希望对大家有所帮助。