Too many threads invoking synchronized method

•

What is DaniWeb IT Discussion Community?

You're currently browsing the Java section within the Software Development category of DaniWeb, a massive community of 423,094 software developers, web developers, Internet marketers, and tech gurus who are all enthusiastic about making contacts, networking, and learning from each other. In fact, there are 4,427 IT professionals currently interacting right now! Registration is free, only takes a minute and lets you enjoy all of the interactive features of the site.

Join our community!

Please support our Java advertiser: Lunarpages Java Web Hosting

Thread Tools Display Modes

Views: 289 | Replies: 1

•

Join Date: Jun 2008

Posts: 8

Reputation: amjad277 is an unknown quantity at this point

Rep Power: 0

Solved Threads: 1

amjad277

Offline

Newbie Poster

Too many threads invoking synchronized method

Jul 2nd, 2008

When one thread is executing a synchronized method for an object, all other threads that invoke synchronized methods for the same object block.

What is happen when too many threads (for the same object) for example 100 Threads invoke this method and want to send data?
In which order can the Threads be executed?
Is there any queueing or buffering here?
If there is buffering, how long does it take to release the buffering data?

 Help with Code Tags 
 java Syntax (Toggle Plain Text) 
private Lock sendMessageLock = new ReentrantLock();
 
public Response send(SMTInitiated data) {
[b]synchronized [/b](sendMessageLock) {
return send(data);
}
}
private Lock sendMessageLock = new ReentrantLock();

public Response send(SMTInitiated data) {
[b]synchronized [/b](sendMessageLock) {
return send(data);
}
}

Last edited by Tekmaven : Jul 14th, 2008 at 10:07 pm. Reason: Added code tags

•

Join Date: Jun 2008

Posts: 4

Reputation: yzg1236 is an unknown quantity at this point

Rep Power: 0

Solved Threads: 1

yzg1236

Offline

Newbie Poster

Re: Too many threads invoking synchronized method

Jul 14th, 2008

1. All threads start to run
2. Some thread get LOCK on some exclusive object
3. Other threads which are requiring this LOCKED object will get into SLEEP
4. After thread in step 2 release LOCKED object, thread manager will NOTIFY all other threads which are SLEEPing and waiting for this LOCKED object.
5. These threads resume running, back to step 1.

So normally system can't not make sure which one is the next resuming thread.

OS have some rules to schedule tasks. But I think you could experiment to get some clue:

 Help with Code Tags 
 java Syntax (Toggle Plain Text) 
private Lock sendMessageLock = new ReentrantLock();
 
public Response send(SMTInitiated data, String threadM) {
      synchronized (sendMessageLock) {
 
            System.out.println(threadM);
            Thread.sleep(100) ;
 
            return send(data);
      }
}
 
public void main () {
    Thread t1 = new Thread(new Runnable(){
          public void run() {
               for (int i=0; i < 100000;i++) 
                  send(data, "t1");
          }
    });
    Thread t2 = new Thread(new Runnable(){
          public void run() {
               for (int i=0; i < 100000;i++) 
                  send(data, "t2");
          }
    });
    Thread t3 = new Thread(new Runnable(){
          public void run() {
               for (int i=0; i < 100000;i++) 
                  send(data, "t3");
          }
    });
    Thread t4 = new Thread(new Runnable(){
          public void run() {
               for (int i=0; i < 100000;i++) 
                  send(data, "t4");
          }
    });
 
    t1.start();
    t2.start();
    t3.start();
    t4.start();
 
 
}
private Lock sendMessageLock = new ReentrantLock();

public Response send(SMTInitiated data, String threadM) {
      synchronized (sendMessageLock) {

            System.out.println(threadM);
            Thread.sleep(100) ;

            return send(data);
      }
}

public void main () {
    Thread t1 = new Thread(new Runnable(){
          public void run() {
               for (int i=0; i < 100000;i++) 
                  send(data, "t1");
          }
    });
    Thread t2 = new Thread(new Runnable(){
          public void run() {
               for (int i=0; i < 100000;i++) 
                  send(data, "t2");
          }
    });
    Thread t3 = new Thread(new Runnable(){
          public void run() {
               for (int i=0; i < 100000;i++) 
                  send(data, "t3");
          }
    });
    Thread t4 = new Thread(new Runnable(){
          public void run() {
               for (int i=0; i < 100000;i++) 
                  send(data, "t4");
          }
    });

    t1.start();
    t2.start();
    t3.start();
    t4.start();


}