在Java中,线程可以通过实现Runnable接口来创建。Runnable接口中定义了一个run()方法,该方法中包含了线程要执行的代码。多个线程可以共享同一个Runnable对象,从而实现资源的共享。
SharedResource类是需要被共享的资源类。下面是一段通过实现Runnable接口来共享SharedResource对象的示例代码:
public class SharedResource implements Runnable {
private int value;
public void run() {
for (int i = 0; i < 5; i++) {
System.out.println(Thread.currentThread().getName() + " : " + value);
value++;
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public class Test {
public static void main(String[] args) {
SharedResource sr = new SharedResource();
Thread t1 = new Thread(sr, "Thread 1");
Thread t2 = new Thread(sr, "Thread 2");
t1.start();
t2.start();
}
}
在这个例子中,我们创建了一个SharedResource类,该类实现了Runnable接口。在run()方法中,我们通过循环输出了value变量的值,并将value加1。我们创建了两个线程t1和t2,并将sr对象作为它们的参数。这样,我们就实现了两个线程共享一个SharedResource对象,从而实现了资源的共享。
下面是另外一个例子,它演示了如何通过Runnable接口实现线程同步:
public class Counter implements Runnable {
private int count;
public synchronized void increment() {
count++;
}
public void run() {
for (int i = 0; i < 10000; i++) {
increment();
}
}
public int getCount() {
return count;
}
}
public class Test {
public static void main(String[] args) throws InterruptedException {
Counter c = new Counter();
Thread t1 = new Thread(c);
Thread t2 = new Thread(c);
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println(c.getCount());
}
}
在这个例子中,我们创建了一个Counter类,该类实现了Runnable接口。我们在increment()方法上加了synchronized关键字来实现线程同步。我们创建了两个线程t1和t2,并将c对象作为它们的参数。这样,我们就实现了两个线程共享一个Counter对象,从而实现了资源的共享和线程同步。在主线程中,我们在t1和t2两个线程执行完之后输出count的值,确保线程同步的正确性。
本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:java实现Runnable接口适合资源的共享 - Python技术站