{"id":2290,"date":"2020-04-01T18:22:25","date_gmt":"2020-04-01T18:22:25","guid":{"rendered":"https:\/\/www.h2kinfosys.com\/blog\/?p=2290"},"modified":"2020-04-07T18:21:33","modified_gmt":"2020-04-07T12:51:33","slug":"java-threads-and-runnables","status":"publish","type":"post","link":"https:\/\/www.h2kinfosys.com\/blog\/java-threads-and-runnables\/","title":{"rendered":"Java Threads and Runnables"},"content":{"rendered":"

Since JDK 1.0 Java language provides built-in support for multithreaded programming.
\nMultithreading is an essential feature in the Java platform<\/a>. Every application has at least one thread. It is called the main thread. This thread can create more threads.
\nIn Java language, each thread is associated with an instance of the class Thread.
\nYou can use class Thread or interface Runnable for thread creation.<\/p>\n

Thread class<\/h2>\n

The class Thread is a basic API to create a Java thread. The Java Virtual Machine allows an application to have multiple threads running concurrently. Threads have priorities, a higher priority means that thread has preferences to be executed. There is also a possibility to mark a thread as a daemon. Daemon thread is a background and low priority thread. It is dedicated to run tasks such as garbage collection. They provide services to support running of user thread. When an application starts there is usually a single non-daemon thread that typically calls method main.
\nLet’s create thread extending the class Thread:<\/p>\n

public<\/span>\u00a0<\/span>c<\/span>lass<\/span>\u00a0MyThread\u00a0<\/span>extends<\/span>\u00a0Thread {<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0<\/span>public<\/span>\u00a0<\/span>void<\/span>\u00a0run() {<\/span>
\n\u00a0 \u00a0 \u00a0 \u00a0 \u00a0System.<\/span>out<\/span>.println(<\/span>“My first thread is running!”<\/span>);<\/span>
\n\u00a0 \u00a0 \u00a0}<\/span>
\n}<\/span><\/p>\n

 <\/p>\n

We don’t need any imports in our class, because class Thread is located in package java.lang. This Java package<\/a> is importing automatically. This code is not enough to run thread. You have to call it for execution. There are two ways to do this:
\nsimply use the method start() for your thread;
\nuse executors.
\nHere we are using the first method to start our thread:<\/p>\n

public<\/span>\u00a0<\/span>class<\/span>\u00a0ThreadExample {<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>static<\/span>\u00a0<\/span>void<\/span>\u00a0main(String[]\u00a0<\/span>args<\/span>) {<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“The main thread id is “<\/span>+ Thread.<\/span>currentThread<\/span>().getId());<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>MyThread\u00a0<\/span>mythread<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0MyThread();<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>mythread<\/span>.start();<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span>
\n}<\/span><\/p>\n

Method start() calls the MyThread method run(). As a result, we will get two threads running concurrently (main thread and thread that we have just created).
\nWhy do we use the method start ()? Why don’t we call the method run () directly? The method start, besides running thread, creates a separate call stack for the thread. Let’s try an example that will help us to understand how it works. We are going to create our thread 3 times and to print its id:<\/p>\n

public<\/span>\u00a0<\/span>class<\/span>\u00a0ThreadExample {<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>static<\/span>\u00a0<\/span>void<\/span>\u00a0main(String[]\u00a0<\/span>args<\/span>) {<\/span>\u00a0 \u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>for<\/span>(<\/span>int<\/span>\u00a0<\/span>i<\/span>\u00a0= 0;\u00a0<\/span>i<\/span>\u00a0< 3;\u00a0<\/span>i<\/span>++) {<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>MyThread\u00a0<\/span>mythread<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0MyThread();<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>mythread<\/span>.start();\u00a0<\/span>\u00a0<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span>
\n}<\/span><\/p>\n

 <\/p>\n

class<\/span>\u00a0MyThread\u00a0<\/span>extends<\/span>\u00a0Thread {<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0<\/span>public<\/span>\u00a0<\/span>void<\/span>\u00a0run() {<\/span>
\n\u00a0 \u00a0 \u00a0 \u00a0 \u00a0System.<\/span>out<\/span>.println(<\/span>“My thread with id “<\/span>+ Thread.<\/span>currentThread<\/span>().getId() +\u00a0<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0<\/span>” is running!”<\/span>);<\/span>
\n\u00a0 \u00a0 \u00a0}<\/span>
\n}<\/span><\/p>\n

The output of the current application will be:<\/p>\n

The main thread id is 1
\nMy thread with id 12 is running!
\nMy thread with id 13 is running!
\nMy thread with id 14 is running!<\/p>\n

In case we will run the thread by calling the method run() we will get:<\/p>\n

The main thread id is 1<\/span>
\nMy thread with id 1 is running!
\nMy thread with id 1 is running!
\nMy thread with id 1 is running!<\/p>\n

As you can understand, in case of method calling the method run(), no new thread is really created.<\/p>\n

Thread Lifecycle<\/h2>\n

There are 6 states of a thread. You can find them in the image:<\/p>\n

\"Java<\/p>\n

A thread is in the New state when it is just created. It has not started yet. After calling the method run(), the thread is moving to the state Runnable. The Waiting or Blocked states mean that the thread is temporarily inactive and it doesn’t consume any CPU. It’s waiting for notification from another thread or waiting for accessing a protected section of code that is currently locked by some another thread. The Timed waiting state is about sleep or a conditional wait of the thread.
\nThe Terminated state can be reached in two cases: the thread finished his work and exited normally or an unhandled error occurred.<\/p>\n

There is the method Thread.getState() that returns the stated of its thread as one of the Enum values(NEW, RUNNABLE, BLOCKED, WAITING, TIMED_WAITING, TERMINATED).<\/p>\n

Here is an example of shaking the state of thread in different places:<\/p>\n

public<\/span>\u00a0<\/span>class<\/span>\u00a0ThreadExample {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>static<\/span>\u00a0<\/span>void<\/span>\u00a0main(String[]\u00a0<\/span>args<\/span>)\u00a0<\/span>throws<\/span>\u00a0InterruptedException {<\/span>\u00a0 \u00a0\u00a0<\/span><\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>MyThread\u00a0<\/span>mythread<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0MyThread();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“After new thread instance creation: “<\/span>\u00a0+\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>mythread<\/span>.getState());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>mythread<\/span>.start();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“After calling the method start(): “<\/span>\u00a0+\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>mythread<\/span>.getState());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread.<\/span>sleep<\/span>(1000);<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“We sent our thread to sleep:\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>“<\/span>+<\/span>mythread<\/span>.getState());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread.<\/span>sleep<\/span>(1000);<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“My Thread is finished: “<\/span>+<\/span>mythread<\/span>.getState());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

}<\/span><\/p>\n

class<\/span>\u00a0MyThread\u00a0<\/span>extends<\/span>\u00a0Thread {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0<\/span>public<\/span>\u00a0<\/span>void<\/span>\u00a0run() {<\/span><\/p>\n

\u00a0 \u00a0 \u00a0 \u00a0 \u00a0System.<\/span>out<\/span>.println(<\/span>“In the thread the state is “<\/span>+\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread.<\/span>currentThread<\/span>().getState());<\/span><\/p>\n

\u00a0 \u00a0 \u00a0 \u00a0 \u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>try<\/span>\u00a0{<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread.<\/span>sleep<\/span>(1500);<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>}\u00a0<\/span>catch<\/span>\u00a0(InterruptedException\u00a0<\/span>e<\/span>) {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>e<\/span>.printStackTrace();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

\u00a0 \u00a0 \u00a0}<\/span><\/p>\n

}<\/span><\/p>\n

 <\/p>\n

The output will be:<\/strong>
\nAfter new thread instance creation: NEW<\/em>
\n After calling the method start(): RUNNABLE<\/em>
\n In the thread the state is RUNNABLE<\/em>
\n We sent our thread to sleep: TIMED_WAITING<\/em>
\n My Thread is finished: TERMINATED<\/em><\/p>\n

In this example, we sent our thread to sleep. Also, we used method sleep in the main thread, because to reach all states of our thread we need to wait.<\/p>\n

The class Thread contains a method to interrupt a thread. If a thread is in the Waiting or the Blocked state, Interrupted Exception will be thrown. After, a thread interrupt status will be set back to the false state. You can check the interrupt status with the method isInterrupted().<\/p>\n

public<\/span>\u00a0<\/span>class<\/span>\u00a0ThreadExample {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>static<\/span>\u00a0<\/span>void<\/span>\u00a0main(String[]\u00a0<\/span>args<\/span>)\u00a0<\/span>throws<\/span>\u00a0InterruptedException {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>MyThread\u00a0<\/span>mythread<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0MyThread();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>mythread<\/span>.start();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>mythread<\/span>.interrupt();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“Interrupted state after calling interrupt(): “<\/span>+\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>mythread<\/span>.isInterrupted());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread.<\/span>sleep<\/span>(1000);<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“Interrupted state in 1 second: “<\/span>\u00a0+\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>mythread<\/span>.isInterrupted());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

}<\/span><\/p>\n

class<\/span>\u00a0MyThread\u00a0<\/span>extends<\/span>\u00a0Thread {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>void<\/span>\u00a0run() {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>try<\/span>\u00a0{<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread.<\/span>sleep<\/span>(3000);<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>}\u00a0<\/span>catch<\/span>\u00a0(InterruptedException\u00a0<\/span>e<\/span>) {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“Thread was interrupted”<\/span>);<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

}<\/span><\/p>\n

The output will be:<\/strong><\/p>\n

Interrupted state after calling interrupt(): true
\nThread was interrupted
\nInterrupted state in 1 second: false<\/p>\n

If a thread is in the runnable state, the method interrupt() will just set interrupted status to true.<\/p>\n

Runnable interface<\/h2>\n

One more way to create a thread is to implement the interface Runnable. The Thread class also implements this interface. Let’s look at the thread created by the implementation of the Runnable:<\/p>\n

public<\/span>\u00a0<\/span>class<\/span>\u00a0RunnableExample {<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>static<\/span>\u00a0<\/span>void<\/span>\u00a0main(String[]\u00a0<\/span>args<\/span>)\u00a0<\/span>throws<\/span>\u00a0InterruptedException {<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>MyThread\u00a0<\/span>mythread<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0MyThread();<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread\u00a0<\/span>thread<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0Thread(<\/span>mythread<\/span>);<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>thread<\/span>.start();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

}<\/span><\/p>\n

class<\/span>\u00a0MyThread\u00a0<\/span>implements<\/span>\u00a0Runnable {<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>void<\/span>\u00a0run() {<\/span>
\n\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“The thread created by implementaion of the Runnable\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>interface”<\/span>);<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

}<\/span><\/p>\n

As you see, you need to use class Thread. We pass our class that implements the Runnable interface into its constructor. After we can call the method start() on it.<\/p>\n

The Thread class has the method getName(). Let’s try to apply it in our example:<\/p>\n

public<\/span>\u00a0<\/span>class<\/span>\u00a0ThreadExample {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>static<\/span>\u00a0<\/span>void<\/span>\u00a0main(String[]\u00a0<\/span>args<\/span>)\u00a0<\/span>throws<\/span>\u00a0InterruptedException {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“The Main thread name is “<\/span>\u00a0+\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0 \u00a0 \u00a0Thread.<\/span>currentThread<\/span>().getName());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>MyThread\u00a0<\/span>mythread<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0MyThread();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread\u00a0<\/span>thread<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0Thread(<\/span>mythread<\/span>);<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>thread<\/span>.start();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

}<\/span><\/p>\n

class<\/span>\u00a0MyThread\u00a0<\/span>implements<\/span>\u00a0Runnable {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>void<\/span>\u00a0run() {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“We created the thread with name “<\/span>\u00a0+ \u00a0 \u00a0 \u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread.<\/span>currentThread<\/span>().getName());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

}<\/span><\/p>\n

The output will be:<\/strong>
\nThe Main thread name is main<\/em>
\n We created the thread with name Thread-0<\/em><\/p>\n

This means that we have created our thread successfully.
\nThere is also a possibility to set a name to your thread. For this, you can use the method setName().
\nThe threads have priorities. You can get the priority of your thread by calling method getPriority(). Here is a simple example:<\/p>\n

public<\/span>\u00a0<\/span>class<\/span>\u00a0ThreadExample {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>static<\/span>\u00a0<\/span>void<\/span>\u00a0main(String[]\u00a0<\/span>args<\/span>)\u00a0<\/span>throws<\/span>\u00a0InterruptedException {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“The current thread priority is “<\/span>\u00a0+\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread.<\/span>currentThread<\/span>().getPriority());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

}<\/span><\/p>\n

The output will be:<\/strong><\/p>\n

The current thread priority is 5<\/em><\/p>\n

This is because, by default, all threads have priority 5. You can change this value by using the method setPriority().
\nThe class Thread has the method join(). It allows one thread to wait until another thread completes its execution.
\nLet’s declare thread that prints its name every half second.<\/p>\n

class<\/span>\u00a0MyThread\u00a0<\/span>implements<\/span>\u00a0Runnable {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>void<\/span>\u00a0run() {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>for<\/span>\u00a0(<\/span>int<\/span>\u00a0<\/span>i<\/span>\u00a0= 0;\u00a0<\/span>i<\/span>\u00a0< 2;\u00a0<\/span>i<\/span>++) {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>try<\/span>\u00a0{<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread.<\/span>sleep<\/span>(500);<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>}\u00a0<\/span>catch<\/span>\u00a0(InterruptedException\u00a0<\/span>e<\/span>) {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>e<\/span>.printStackTrace();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>System.<\/span>out<\/span>.println(<\/span>“The thread “<\/span>\u00a0+ Thread.<\/span>currentThread<\/span>().getName()+\u00a0<\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>” is running”<\/span>);<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

}<\/span><\/p>\n

Now we will create two instances of this thread and run them. Here is the example without the join() method:<\/p>\n

public<\/span>\u00a0<\/span>class<\/span>\u00a0ThreadsExample {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>static<\/span>\u00a0<\/span>void<\/span>\u00a0main(String[]\u00a0<\/span>args<\/span>)\u00a0<\/span>throws<\/span>\u00a0InterruptedException {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread\u00a0<\/span>thread1<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0Thread(<\/span>new<\/span>\u00a0MyThread());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread\u00a0<\/span>thread2<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0Thread(<\/span>new<\/span>\u00a0MyThread());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>thread1<\/span>.start();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>thread2<\/span>.start();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

}<\/span><\/p>\n

The output:<\/strong><\/p>\n

The thread Thread-1 is running<\/em>
\n The thread Thread-0 is running<\/em>
\n The thread Thread-1 is running<\/em>
\n The thread Thread-0 is running<\/em><\/p>\n

As you see, two threads run concurrently. Let’s ask one of the threads to wait while another one will finish his work:<\/p>\n

public<\/span>\u00a0<\/span>class<\/span>\u00a0ThreadsExample {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>public<\/span>\u00a0<\/span>static<\/span>\u00a0<\/span>void<\/span>\u00a0main(String[]\u00a0<\/span>args<\/span>)\u00a0<\/span>throws<\/span>\u00a0InterruptedException {<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread\u00a0<\/span>thread1<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0Thread(<\/span>new<\/span>\u00a0MyThread());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>Thread\u00a0<\/span>thread2<\/span>\u00a0=\u00a0<\/span>new<\/span>\u00a0Thread(<\/span>new<\/span>\u00a0MyThread());<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>thread1<\/span>.start();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>thread1<\/span>.join();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>\u00a0 \u00a0\u00a0<\/span><\/span>thread2<\/span>.start();<\/span><\/p>\n

\u00a0 \u00a0\u00a0<\/span><\/span>}<\/span><\/p>\n

}<\/span><\/p>\n

The output:<\/strong>
\nThe thread Thread-0 is running<\/em>
\n The thread Thread-0 is running<\/em>
\n The thread Thread-1 is running<\/em>
\n The thread Thread-1 is running<\/em><\/p>\n

Now, the Thread-1 started to run just after Thread-0 was completed. The method join() has overridden versions. They allow waiting for the completion of another thread just a limited period of time.
\nThe class Thread has also method is Alive() that returns true if a thread is just created or already running.<\/p>\n","protected":false},"excerpt":{"rendered":"

Since JDK 1.0 Java language provides built-in support for multithreaded programming. Multithreading is an essential feature in the Java platform. Every application has at least one thread. It is called the main thread. This thread can create more threads. In Java language, each thread is associated with an instance of the class Thread. You can […]<\/p>\n","protected":false},"author":1,"featured_media":2407,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[42],"tags":[58,457,456],"class_list":["post-2290","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-java-tutorials","tag-java","tag-runnables","tag-threads"],"_links":{"self":[{"href":"https:\/\/www.h2kinfosys.com\/blog\/wp-json\/wp\/v2\/posts\/2290","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.h2kinfosys.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.h2kinfosys.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.h2kinfosys.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.h2kinfosys.com\/blog\/wp-json\/wp\/v2\/comments?post=2290"}],"version-history":[{"count":0,"href":"https:\/\/www.h2kinfosys.com\/blog\/wp-json\/wp\/v2\/posts\/2290\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.h2kinfosys.com\/blog\/wp-json\/wp\/v2\/media\/2407"}],"wp:attachment":[{"href":"https:\/\/www.h2kinfosys.com\/blog\/wp-json\/wp\/v2\/media?parent=2290"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.h2kinfosys.com\/blog\/wp-json\/wp\/v2\/categories?post=2290"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.h2kinfosys.com\/blog\/wp-json\/wp\/v2\/tags?post=2290"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}