Could you please create a ThreadPool.java file to perform thread operations. For this exercise you should create your own implementation of a thread pool. In preparation for thisexercise, you should change the ImageProcessorMT class so that it implements the Runnable interface.Your thread pool will manage threads that run your new ImageProcessorMTs. The thread pool class itselfshould also implement Runnable.The thread pool should offer a constructor that receives the size of the thread pool as a parameter.The thread pool has relatively simple functionality. It should be possible to submit a task(i.e. an ImageProcessorMT) to the thread pool. This does not mean that the task will actually run yet,just that the thread pool is aware of it and keeps it in a waiting list. The number of ImageProcessorMTsthat are added can exceed the number of threads available in the thread pool.It should also be possible to start the thread pool. This means that the thread pool will then run asmany ImageProcessorMTs as it can up to its size. For example, if the thread pool size is 5, but 10ImageProcessorMTs have been added, it can only run 5.When any ImageProcessorMT has terminated, a new one from the waiting list should be started by thethread pool (if one exists). The thread pool should continue to do this until the waiting list is empty, whenit should itself terminate.The thread pool should offer a join() method that causes the calling thread to wait until the thread poolhas terminated.Note that when you change ImageProcessorMT to implement Runnable, its run() method works the sameway as it does in ImageProcessorST: it processes the image and then exits (terminating the thread). Youmight wish to add a boolean and a getter to ImageProcessorMT that signals that the run method hasterminated, hence the result is available, and the thread pool can now run another thread (if the waitinglist was not empty).

Answered: Image /qna-images/answer/02455683-1190-4679-9412-e7b47b4e493d.jpg

For this exercise you should create your own implementation of a thread pool. In preparation for this exercise, you should change the ImageProcessorMT class so that it implements the Runnable interface. Your thread pool will manage threads that run your new ImageProcessorMTs. The thread p0ol class itself should also implement Runnable. The thread pool should offer a constructor that receives the size of the thread pool as a parameter. The thread pool has relatively simple functionality. It should be possible to submit a task (i.e. an ImageProcessorMT) to the thread pool. This does not mean that the task will actually run yet, just that the thread pool is aware of it and keeps it in a waiting list. The number of ImageProcessorMTs that are added can exceed the number of threads available in the thread pool.

For this exercise you should create your own implementation of a thread pool. In preparation for this exercise, you should change the ImageProcessorMT class so that it implements the Runnable interface. Your thread pool will manage threads that run your new ImageProcessorMTs. The thread p0ol class itself should also implement Runnable. The thread pool should offer a constructor that receives the size of the thread pool as a parameter. The thread pool has relatively simple functionality. It should be possible to submit a task (i.e. an ImageProcessorMT) to the thread pool. This does not mean that the task will actually run yet, just that the thread pool is aware of it and keeps it in a waiting list. The number of ImageProcessorMTs that are added can exceed the number of threads available in the thread pool.

Database System Concepts

7th Edition

ISBN:9780078022159

Author:Abraham Silberschatz Professor, Henry F. Korth, S. Sudarshan

Publisher:Abraham Silberschatz Professor, Henry F. Korth, S. Sudarshan

Chapter1: Introduction

Section: Chapter Questions

Problem 1PE

See similar textbooks

Similar questions

#include <pthread.h>#include <stdio.h>#include <unistd.h>#include <stdlib.h> int count = 0; void *threadfunc(void *arg){ cout<<"Thread Complete\n"; count++; return NULL; } int main(){ count = 0; pthread_t A,B,C;pthread_create(&A, NULL, threadfunc, NULL); pthread_create(&B, NULL, threadfunc, NULL); pthread_create(&C, NULL, threadfunc, NULL); while(count<50) {pthread_join(A, NULL); if(count<50) pthread_join(B, NULL); if(count<50) pthread_join(C, NULL); } return 0; } What is wrong?
Build a class that extends from the Java FX Application class. Name this class - Thread and it needs to use Runnable. You DO NOT NEED to build any GUI code, just build the code to make the thread work. Have the Thread code just loop and print out “Hello World” 100 times. Build a main method in this class which will instantiate this class and start the Thread.
What is this code doing exactly? Please explain in detail so I can better understand the process. Thank you #include <pthread.h> #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <string.h> #define MAX 100 static void * threadFunc (void *arg) { char *str = (char *) arg; int count = 0; printf("\nThread: threadFunc started \n"); while(1) { sleep(1); printf("\n threadFunc: executing loop \n"); } sleep(5); printf("\nThread: threadFunc exiting \n"); } int main(int argc, char *argv[]) // init thread or main thread { pthread_t t1_id; void *res; int s; int count; s = pthread_create(&t1_id, NULL, threadFunc, NULL); if ( s != 0 ) //if creating the new thread is successful, then s will be zero. { perror("Thread create error"); } for (count = 0; count < 10; count++) { sleep(2); printf("\n main thread: count value = (%d) \n", count); } pthread_cancel(t1_id); printf("main thread: exiting now \n "); pthread_exit(NULL);…
A class that extends Thread must override ____ method ? start() run() init() sleep()
Write a multithreaded Hello World program using OpenMP. Have each thread say “Hello world” along with its thread ID and the number of threads the program is using.Run the program with as many threads as your computer will allow. Then try setting the thread count to a different number. please post:- The source code.- A screenshot of the program running.- A screenshot of the program running with a different thread count.
No plagarism please! with comments and output screenshot is must for Upvote. Thank you!
Needed c++ coding please do it in 10 minutes and get thumb up
Please answer the follwoing regarding the java code: When looking at the code below, assume that the MyThread and MyRunnable classes are correctly implemented in other files. How many threads are there in the program shown below? (Be careful to consider ALL the threads!)
I added a loop while (true) to both def reader (): and def writer () but still not working in way when I run the code down will not stop to the user click ctrl +c or to be run to the end import threading as threadimport random global x #Shared Datax = 0lock = thread.Lock() #Lock for synchronising access def Reader(): while(true): global x print('Reader is Reading!') lock.acquire() #Acquire the lock before Reading (mutex approach) print('Shared Data:', x) lock.release() #Release the lock after Reading print() def Writer(): while(true) global x print('Writer is Writing!') lock.acquire() #Acquire the lock before Writing x += 1 #Write on the shared memory print('Writer is Releasing the lock!') lock.release() #Release the lock after Writing print() if __name__ == '__main__': for i in range(0, 10): randomNumber = random.randint(0, 100) #Generate a Random number between 0 to 100…
How does this method cause memory leaks? How do I make it multi-thread safe? I have this JUnit test method that checks if my method is working. What it does is to. Inherit @Before and @After methods from BaseTest Since for every class, a session is created before, use it for ServiceTest.testUpdate() when we have to use session.save. ----------------------------------------------------------------------------------------------------------------------- public class BaseTest{ @Autowired protected SessionFactory sessionFactory; protected Session session; @Before public void createSession() { session = sessionFactory.openSession(); } @After public void closeSession(){ if (session != null) { session.flush(); session.close(); } } } public class ServiceTest extends BaseTest{ @Autowired private FoodService foodService; @Test public void testUpdate() { Food food= new Food("Japanese", "Ramen"); session.save(student); int id = (int) session.getIdentifier(student); session.flush();…
For the following code I get an error: Exception in thread "main" java.lang.Error: Unresolved compilation problems: The type LinkedListIn is not generic; it cannot be parameterized with arguments <String> The type LinkedListIn is not generic; it cannot be parameterized with arguments <> at linkedList.LinkedListTester.main(LinkedListTester.java:5) How can I fix it? package linkedList; public class LinkedListTester { public static void main(String[] args) { LinkedListIn<String> list = new LinkedListIn<>(); list.display(); list.add("Station 1"); list.add("Station 2"); list.add("Station 3"); list.add("Station 4"); // Print the linked list System.out.println("All Stations: " + list); // Accessing the first item System.out.println("First stop: " + list.getFirst()); // Accessing the last item System.out.println("Last stop: " + list.getLast()); // Removing the first item System.out.println("Left this station: " + list.removeFirst()); //…
Modify and run the program shown below in the following way. There is an array of 20 elements defined in the program. The elements of the array are: [20 18 16 14 12 10 8 6 4 2 -20 -18 -16 -14 -12 -10 -8 -6 -4 -2]. Thread 1 adds the first five elements [20, 18, 16, 14, 12], Thread 2 adds the next five elements [10, 8, 6, 4, 2], ..., Thread 4 adds the last five elements [-10 -8 -6 -4 -2]. Finally, the sum of all the 20 elements is printed by the main program. include <pthread.h> #include <stdio.h> #include <stdlib.h> #define NUM_THREADS 3 int counter=1; void *PrintHello(void *threadid) { counter = 2*counter+ (int) threadid; printf("\n Thread Id: %d Counter: %d\n", threadid, counter); pthread_exit(NULL); } int main(int argc, char *argv[]) { pthread_t threads[NUM_THREADS]; int rc, t; for(t=0;t<NUM_THREADS;t++){ printf("Creating thread %d\n", t); rc = pthread_create(&threads[t], NULL, PrintHello, (void *)t); if (rc){ printf("ERROR; return…