Reply to thread

Message

<blockquote data-quote="azam426" data-source="post: 11150565" data-attributes="member: 55428">/*FileName: ATEST16.javaThe output of this example is as follows:&nbsp;Entered the testcase&nbsp;Synchronize to prevent access to shared data&nbsp;Create/start the thread&nbsp;Thread Thread-1: Entered&nbsp;Thread Thread-2: Entered&nbsp;Wait a bit until we're 'done' with the shared data&nbsp;Thread Thread-3: Entered&nbsp;Unlock shared data&nbsp;Thread Thread-1: Start critical section, in synchronized block&nbsp;Thread Thread-1: End critical section, leave synchronized block&nbsp;Thread Thread-2: Start critical section, in synchronized block&nbsp;Thread Thread-2: End critical section, leave synchronized block&nbsp;Thread Thread-3: Start critical section, in synchronized block&nbsp;Thread Thread-3: End critical section, leave synchronized block&nbsp;Wait for the threads to complete&nbsp;Testcase completed*/import java.lang.*;&nbsp;&nbsp;public class ATEST16 {&nbsp;&nbsp; public final static int NUMTHREADS&nbsp;&nbsp; = 3;&nbsp;&nbsp; public static int sharedData&nbsp; = 0;&nbsp;&nbsp; public static int sharedData2 = 0;&nbsp;&nbsp; /* Any real java object or array would suit for synchronization&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; */&nbsp;&nbsp; /* We invent one here since we have two unique data items to synchronize */&nbsp;&nbsp; /* An in this simple example, they're not in an object&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; */&nbsp;&nbsp; static class theLock extends Object {&nbsp;&nbsp; }&nbsp;&nbsp; static public theLock lockObject = new theLock();&nbsp;&nbsp;&nbsp; static class theThread extends Thread {&nbsp; &nbsp; &nbsp; public void run() {&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; System.out.print(&quot;Thread &quot; + getName() + &quot;: Entered\n&quot;);&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; synchronized (lockObject) {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; /********** Critical Section *******************/&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; System.out.print(&quot;Thread &quot; + getName() +&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; &quot;: Start critical section, in synchronized block\n&quot;);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ++sharedData; --sharedData2;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; System.out.print(&quot;Thread &quot; + getName() +&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; &quot;: End critical section, leave synchronized block\n&quot;);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; /********** Critical Section *******************/&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; }&nbsp; &nbsp; &nbsp; }&nbsp;&nbsp; }&nbsp;&nbsp;&nbsp; public static void main(String argv[]) {&nbsp; &nbsp; &nbsp; theThread threads[] = new theThread[NUMTHREADS];&nbsp; &nbsp; &nbsp; System.out.print(&quot;Entered the testcase\n&quot;);&nbsp;&nbsp; &nbsp; &nbsp; System.out.print(&quot;Synchronize to prevent access to shared data\n&quot;);&nbsp; &nbsp; &nbsp; synchronized (lockObject) {&nbsp;&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; System.out.print(&quot;Create/start the thread\n&quot;);&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; for (int i=0; i&lt;NUMTHREADS; ++i) {&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; threads = new theThread();&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; threads.start();&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; }&nbsp;&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; System.out.print(&quot;Wait a bit until we're 'done' with the shared data\n&quot;);&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; try {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Thread.sleep(3000);&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; }&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; catch (InterruptedException e) {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; System.out.print(&quot;sleep interrupted\n&quot;);&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; }&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; System.out.print(&quot;Unlock shared data\n&quot;);&nbsp; &nbsp; &nbsp; }&nbsp;&nbsp; &nbsp; &nbsp; System.out.print(&quot;Wait for the threads to complete\n&quot;);&nbsp; &nbsp; &nbsp; for(int i=0; i &lt;NUMTHREADS; ++i) {&nbsp; &nbsp; &nbsp; threads.join();&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; }&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; catch (InterruptedException e) {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; System.out.print(&quot;Join interrupted\n&quot;);&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; }&nbsp; &nbsp; &nbsp; }&nbsp;&nbsp; &nbsp; &nbsp; System.out.print(&quot;Testcase completed\n&quot;);&nbsp; &nbsp; &nbsp; System.exit(0);&nbsp;&nbsp; }&nbsp;}</blockquote>

[QUOTE="azam426, post: 11150565, member: 55428"] /* FileName: ATEST16.java The output of this example is as follows: Entered the testcase Synchronize to prevent access to shared data Create/start the thread Thread Thread-1: Entered Thread Thread-2: Entered Wait a bit until we're 'done' with the shared data Thread Thread-3: Entered Unlock shared data Thread Thread-1: Start critical section, in synchronized block Thread Thread-1: End critical section, leave synchronized block Thread Thread-2: Start critical section, in synchronized block Thread Thread-2: End critical section, leave synchronized block Thread Thread-3: Start critical section, in synchronized block Thread Thread-3: End critical section, leave synchronized block Wait for the threads to complete Testcase completed */ import java.lang.*; public class ATEST16 { public final static int NUMTHREADS = 3; public static int sharedData = 0; public static int sharedData2 = 0; /* Any real java object or array would suit for synchronization */ /* We invent one here since we have two unique data items to synchronize */ /* An in this simple example, they're not in an object */ static class theLock extends Object { } static public theLock lockObject = new theLock(); static class theThread extends Thread { public void run() { System.out.print("Thread " + getName() + ": Entered\n"); synchronized (lockObject) { /********** Critical Section *******************/ System.out.print("Thread " + getName() + ": Start critical section, in synchronized block\n"); ++sharedData; --sharedData2; System.out.print("Thread " + getName() + ": End critical section, leave synchronized block\n"); /********** Critical Section *******************/ } } } public static void main(String argv[]) { theThread threads[] = new theThread[NUMTHREADS]; System.out.print("Entered the testcase\n"); System.out.print("Synchronize to prevent access to shared data\n"); synchronized (lockObject) { System.out.print("Create/start the thread\n"); for (int i=0; i<NUMTHREADS; ++i) { threads[i] = new theThread(); threads[i].start(); } System.out.print("Wait a bit until we're 'done' with the shared data\n"); try { Thread.sleep(3000); } catch (InterruptedException e) { System.out.print("sleep interrupted\n"); } System.out.print("Unlock shared data\n"); } System.out.print("Wait for the threads to complete\n"); for(int i=0; i <NUMTHREADS; ++i) { threads[i].join(); } catch (InterruptedException e) { System.out.print("Join interrupted\n"); } } System.out.print("Testcase completed\n"); System.exit(0); } }[/i][/i][/i] [/QUOTE]

Verification

Dawasata paya keeyak thibeda?

Search

Latest ads

Reply to thread