使用线程锁定系统的偶数奇数
今天，我在Thread上进行了一些练习，并试图创建一个偶数奇数程序。我使用同步创建了它，并且运行良好。但是，当我尝试使用Lock进行相同的操作时，我就卡住了。
以下是我尝试执行的代码。
public class OddEvenNumberThreadLock {
public static void main(String args[]) {
SharedObject sharedObject = new SharedObject();
Thread evenThread = new Thread(new EvenNumber(sharedObject));
Thread oddThread = new Thread(new OddNumber(sharedObject));
evenThread.start();
oddThread.start();
}
}
class EvenNumber implements Runnable {
SharedObject object;
public EvenNumber(SharedObject object) {
this.object = object;
}
@Override
public void run() {
for (int i = 0; i <= 100; i = i + 2) {
while (!object.isOdd()) {
object.getLock().lock();
try {
System.out.println("Even : " + i);
object.setOdd(true);
} catch (Exception e) {
e.printStackTrace();
} finally {
object.getLock().unlock();
}
}
}
}
}
class OddNumber implements Runnable {
SharedObject object;
public OddNumber(SharedObject object) {
this.object = object;
}
@Override
public void run() {
for (int i = 1; i <= 100; i = i + 2) {
while (object.isOdd()) {
object.getLock().lock();
try {
System.out.println("Odd : " + i);
object.setOdd(false);
} catch (Exception e) {
e.printStackTrace();
} finally {
object.getLock().unlock();
}
}
}
}
}
class SharedObject {
private Lock lock;
private boolean isOdd;
public SharedObject() {
this.lock = new ReentrantLock();
}
public boolean isOdd() {
return isOdd;
}
public void setOdd(boolean isOdd) {
this.isOdd = isOdd;
}
public Lock getLock() {
return lock;
}
public void setLock(Lock lock) {
this.lock = lock;
}
}
我还有一个问题，例如在同步的情况下，我们使用notify方法来通知其他线程。在Lock的情况下，我们如何实现这一目标。
慕哥62875431回答
-
侃侃尔雅
据我所知，您要实现自己的两个线程以乒乓方式打印偶数和奇数。您想要的行为ReentrantLock比使用synchronizedblock更容易实现，因为synchronized它总是不公平的，但是您可以ReentrantLock使用适当的构造函数使行为更加公平。这是Locks程序的外观：public class App { public static void main(String args[]) { SharedObject sharedObject = new SharedObject(); Thread evenThread = new Thread(new EvenNumber(sharedObject)); Thread oddThread = new Thread(new OddNumber(sharedObject)); evenThread.start(); oddThread.start(); }}class EvenNumber implements Runnable { SharedObject object; public EvenNumber(SharedObject object) { this.object = object; } public void run() { int i = 0; while(i <= 100) { object.getLock().lock(); try { if (!object.isOdd()) { System.out.println("Even : " + i); i = i + 2; object.setOdd(true); } } catch (Exception e) { e.printStackTrace(); } finally { object.getLock().unlock(); } } }}class OddNumber implements Runnable { SharedObject object; public OddNumber(SharedObject object) { this.object = object; } public void run() { int i = 1; while(i <= 100) { object.getLock().lock(); try { if(object.isOdd()) { System.out.println("Odd : " + i); i = i + 2; object.setOdd(false); } } catch (Exception e) { e.printStackTrace(); } finally { object.getLock().unlock(); } } }}class SharedObject { private Lock lock; private boolean isOdd; public SharedObject() { this.lock = new ReentrantLock(true); } public boolean isOdd() { return isOdd; } public void setOdd(boolean isOdd) { this.isOdd = isOdd; } public Lock getLock() { return lock; } public void setLock(Lock lock) { this.lock = lock; }}
随时随地看视频慕课网APP
相关分类
Java